lucasbru commented on code in PR #19700:
URL: https://github.com/apache/kafka/pull/19700#discussion_r2093593434
##########
tests/kafkatest/tests/streams/streams_eos_test.py:
##########
@@ -160,10 +168,16 @@ def abort_streams(self, keep_alive_processor1,
keep_alive_processor2, processor_
self.wait_for_startup(monitor1, keep_alive_processor1)
def wait_for_startup(self, monitor, processor):
- self.wait_for(monitor, processor, "StateChange: REBALANCING ->
RUNNING")
+ if self.group_protocol == "classic":
+ self.wait_for(monitor, processor, "StateChange: REBALANCING ->
RUNNING")
+ else:
+ # In the streams group protocol, not all members will take part in
the rebalance.
+ # We can indirectly observe the progress of the group by seeing
the member epoch being bumped.
+ self.wait_for(monitor, processor, "MemberEpochBump")
self.wait_for(monitor, processor, "processed [0-9]* records from
topic")
- def wait_for(self, monitor, processor, output):
+ @staticmethod
+ def wait_for(monitor, processor, output):
monitor.wait_until(output,
- timeout_sec=480,
+ timeout_sec=60,
Review Comment:
Good catch. Did not want to commit that.
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
