bbejeck opened a new pull request, #21034: URL: https://github.com/apache/kafka/pull/21034
cherry-picked from trunk: ``` MINOR: Prevent re-join flakiness in test_fencing_static_consumer by ensuring conflicting static consumers terminate (#20772) Related discussion: https://github.com/apache/kafka/pull/20594#pullrequestreview-3362587453 ### Problem The test `OffsetValidationTest.test_fencing_static_consumer` failed when executed with `fencing_stage=stable` and `group_protocol=consumer`. It timed out while waiting for the group to become empty because the conflicting static consumers re-joined after the original members stopped, keeping the group non-empty and causing the timeout. ### Fix For the consumer-protocol path, the test now waits for all conflicting consumer processes to terminate before stopping the original static members. This ensures that each conflicting consumers is fully fenced and cannot re-join the group after the original members stop. Reviewers: Chia-Ping Tsai <[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]
