We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
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
use the example of [consumer group|https://github.com/Shopify/sarama/tree/master/examples/consumergroup]
Disable the AutoCommit by this config.Consumer.Offsets.AutoCommit.Enable = false
Show status via ./kafka-consumer-groups.sh --describe --group XX --bootstrap-server XX TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID
Why CURRENT-OFFSET never changed? It will change when AutoCommit enabled.
The text was updated successfully, but these errors were encountered:
because you are not be able to Commit manually, #1570
Sorry, something went wrong.
Dupe of #1570
No branches or pull requests
Versions
Problem Description
use the example of [consumer group|https://github.com/Shopify/sarama/tree/master/examples/consumergroup]
Disable the AutoCommit by this
config.Consumer.Offsets.AutoCommit.Enable = false
Show status via ./kafka-consumer-groups.sh --describe --group XX --bootstrap-server XX
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID
Why CURRENT-OFFSET never changed? It will change when AutoCommit enabled.
The text was updated successfully, but these errors were encountered: