shoemoney opened a new pull request, #25732: URL: https://github.com/apache/camel/pull/25732
Bug: KafkaFetchRecords.isReady returns true by default and only checks hasReadyNodes when consumer is KafkaConsumer. With group.protocol=consumer Kafka creates AsyncKafkaConsumer which does not match, so readiness stays UP when not ready. Reflection failures also return true. Fix: Initialize ready false and only set true on successful hasReadyNodes. Add else branch for unknown consumer types to fail closed. On exception set ready false. Evidence: Manual RED to GREEN verification. Claude Code on behalf of shoemoney -- 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]
