stantheman0128 opened a new pull request, #23154: URL: https://github.com/apache/kafka/pull/23154
ClassicKafkaConsumer has no background thread, so poll() is what drives JoinGroup and SyncGroup for the classic group protocol. In testConsumerGroupServiceWithAuthenticationSuccess, the second waitForCondition checked group visibility but never called poll() again. If the handshake wasn't finished after the first successful poll, nothing pushed it forward, and the test timed out under load. This keeps the two waitForCondition blocks separate, so the auth-failure and missing-group-visibility messages stay distinguishable, and just adds poll() to the second one. Verified with the test class run 30 times with the fix (all green), 60 times reverted under a warm daemon (all green, does not reproduce the flake), and 30 times reverted under artificial CPU load (4/30 red, matching the ~10% rate reported before this change). Co-Authored-By: Claude Sonnet 5 <[email protected]> -- 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]
