orpiske commented on pull request #6438: URL: https://github.com/apache/camel/pull/6438#issuecomment-968872502
I test this and it is failing. The problem is that the current consumer initialization is unnecessarily complex (it's a leftover from the previous logic) and it depends on the status of the reconnecting flag: https://github.com/apache/camel/blob/main/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaFetchRecords.java#L128-L136 Using your patch, I did a small refactoring to simplify the initialization logic: https://github.com/orpiske/camel/commit/79a39b7cb1f08ba033bf2f27d249c787da5c9002 -- 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: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
