apalan60 opened a new pull request, #20772: URL: https://github.com/apache/kafka/pull/20772
Related discussion: https://github.com/apache/kafka/pull/20594#pullrequestreview-3362587453 - Problem The consumer-protocol branch of the test was flaky, timing out while waiting for the group to become empty. The conflicting static consumers were not actually fenced, as they immediately re-joined after the existing nodes stopped, keeping the group non-empty and causing the timeout. - Fix In the consumer-protocol path, the test now waits for all conflicting consumer processes to terminate and log an `UnreleasedInstanceIdException` before stopping the original static members. This ensures that each conflicting instance ID is fully fenced and cannot re-join the group. -- 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]
