bbejeck commented on code in PR #20957:
URL: https://github.com/apache/kafka/pull/20957#discussion_r2557562833
##########
tests/kafkatest/tests/client/consumer_test.py:
##########
@@ -330,10 +330,19 @@ def test_fencing_static_consumer(self,
num_conflict_consumers, fencing_stage, me
timeout_sec=10,
err_msg="Timed out waiting for the fenced consumers to
stop")
else:
- # Consumer protocol: Existing members should remain active and
new conflicting ones should not be able to join.
- self.await_consumed_messages(consumer)
- assert num_rebalances == consumer.num_rebalances(), "Static
consumers attempt to join with instance id in use should not cause a rebalance"
Review Comment:
The trouble with going between different repos
--
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]
