You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
consume() currently always auto-commits, regardless of the setting for 'enable.auto.commit'. I believe this is an upstream issue in confluent-kafka, see confluentinc/confluent-kafka-python#1299
It might be nice to adjust the example in the readme in the meantime to use poll() instead (which works as expected), or add a comment to it that the functionality is currently broken.
I'll be happy to make a PR for an updated example if that's desired. Might save someone else some time trying to track down this issue.
The text was updated successfully, but these errors were encountered:
consume()
currently always auto-commits, regardless of the setting for 'enable.auto.commit'. I believe this is an upstream issue in confluent-kafka, see confluentinc/confluent-kafka-python#1299It might be nice to adjust the example in the readme in the meantime to use
poll()
instead (which works as expected), or add a comment to it that the functionality is currently broken.I'll be happy to make a PR for an updated example if that's desired. Might save someone else some time trying to track down this issue.
The text was updated successfully, but these errors were encountered: