-
Notifications
You must be signed in to change notification settings - Fork 483
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.
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
High-level balanced KafkaConsumer does not respect -e option #86
Labels
Comments
Im working on this |
@edenhill Any updates on this one please? |
+1 running into this as well |
I'm running into this problem as well. Is the fix being released anytime soon, @edenhill ? |
This is an issue for me too @edenhill. Hope you are well. |
Same here. Hope it will be fixed someday. |
This issue was closed.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hi,
When using the balanced high level consumer with the -e flag, it does not exit immediately after the last message is consumed. The -e flags works fine with the regular consumer.
kafkacat -b mybroker -e -G mygroup topic1
% Reached end of topic topic1 [0] at offset 26
The text was updated successfully, but these errors were encountered: