Releases: rabbitmq/rabbitmq-stream-go-client
Releases · rabbitmq/rabbitmq-stream-go-client
v1.4.10
What's Changed
Enhancements
- Improve the producer creation step by @Gsantomaggio in #352
- check super stream creation by @Gsantomaggio in #355
Full Changelog: v1.4.9...v1.4.10
v1.4.9
v1.4.8
What's Changed
Bug Fixes
- Check version when serverProperties is not empty and < 3.11.0 by @Gsantomaggio in #345
Full Changelog: v1.4.7...v1.4.8
v1.4.7
What's Changed
Enhancements
- Reduce
minBatchPublishingDelay
to 1ms by @hiimjako in #333 - Add BatchSend to HA Producer by @hiimjako in #334
Bug Fixes
- pkg/stream: fix the error that could occur due to nil option by @bailantaotao in #331
- fix offset of single active consumer reset to 0 by @Darthmineboy in #336
- Fix the reconnection logic for parallel writes with HA Producer. by @hiimjako in #335
- Fix flush interval by @Darthmineboy in #338
Documentation
New Contributors
- @bailantaotao made their first contribution in #331
- @Darthmineboy made their first contribution in #336
Full Changelog: v1.4.6...v1.4.7
v1.4.6
Milestone
Enhancements
- Bump github.com/spf13/cobra from 1.8.0 to 1.8.1 by @dependabot in #316
- Improve the message log by @Gsantomaggio in #319
- Force localhost when lookup the metadata by @Gsantomaggio in #317
- Add manual commit for super stream consumer by @Gsantomaggio in #323
Deprecation
- Deprecate
LastConsumed
method by @Gsantomaggio in #324
The method does not indicate the last message consumed of the stream but the last stored offset.
The method was added to help the user but created confusion.env.QueryOffset(consumerName, streamName)
should be used,
like:
offset, err := env.QueryOffset(consumerName, streamName)
/// you may need to do offset+1 to restart from the next message
consumer, err := env.NewConsumer(streamName, handleMessages, stream.
NewConsumerOptions().
SetManualCommit().
SetOffset(stream.OffsetSpecification{}.Offset(offset)).SetConsumerName(consName),
)
Full Changelog: v1.4.5...v1.4.6
v.1.4.5
Milestone
Enhancements
- Expose the RPC TImeout call by @Gsantomaggio in #313
- Bump github.com/klauspost/compress from 1.17.8 to 1.17.9 by @dependabot in #314
Bug Fixes
- Fix multi uris connection by @Gsantomaggio in #310
Full Changelog: v1.4.4...v1.4.5
v1.4.4
Milestone
Bug Fixes
- change the default value for
last_stored_offset
by @Gsantomaggio in #307
Full Changelog: v1.4.3...v1.4.4
v1.4.3
Milestone
Enhancements
- Add auto-commit to the super stream consumer by @Gsantomaggio in #305
Deprecation
environment.StreamStats.LastOffset()
is now deprecated.
The method name may be misleading. It does not indicate the last offset of the stream. It indicates the last uncommitted chunk id. This information is not necessary. The user should use CommittedChunkId()
.
Full Changelog: v1.4.2...v1.4.3
v1.4.2
Milestone
Enhancements
- Filtering for super stream by @Gsantomaggio in #300
- Bump golang.org/x/net from 0.17.0 to 0.23.0 by @dependabot in #301
Full Changelog: v1.4.1...v1.4.2
v1.4.1
Milestone
Enhancements
-
Reduce memory allocation in
handlerDeliver
by @hiimjako in #294
This fix improves the ~20% performance. See #294 (comment) -
Bump github.com/klauspost/compress from 1.17.7 to 1.17.8 by @dependabot in #292
New Contributors
Full Changelog: v1.4.0...v1.4.1