Closed Gsantomaggio closed 5 months ago
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 it created confusion. env.QueryOffset(consumerName, streamName) should be used
env.QueryOffset(consumerName, streamName)
ref: https://github.com/rabbitmq/rabbitmq-stream-go-client/issues/321
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 it created confusion.
env.QueryOffset(consumerName, streamName)
should be usedref: https://github.com/rabbitmq/rabbitmq-stream-go-client/issues/321