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