New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

How to ensure all messages are read #251

Open

rafaelvicio opened this issue Mar 13, 2019 · 0 comments

rafaelvicio commented Mar 13, 2019

How can a guarantee be made that all messages that are on the topic have been read by someone consumed?

For example:

When sending 3 messages to a topic X without any consumer reading from topic X

When a new consumer connects to the X topic, it will wait for a message to be published to process it.

This is the default behavior because of a configuration:

recoveryOffset - recovery position (time) which will used to recover subscription in case of OffsetOutOfRange error, defaults to Kafka.LATEST_OFFSET

How can I ensure that I read messages 1 to 3 without repeating messages that I have already processed?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment