ddione84 commented on issue #32585: URL: https://github.com/apache/airflow/issues/32585#issuecomment-1862516047
> @ikholodkov @ddione84 I just created #36272 to fix the issue. Could you please test it? > > Also, I suggest testing the current version of the operator with config `enable.auto.commit: false`; As you see in my PR, we commit the consumed messages manually, so if the auto-commit is enabled, the consumer will try to commit the consumed offsets periodically, which may be the reason for your issue (the automatic commit doesn't find any offset to commit). Hi have tested this for my pipelines and it's seems to be working fine. thank you -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
