Skip to content

Commit

Permalink
rptest: Wait for Stable before start cgrups tests
Browse files Browse the repository at this point in the history
- Its been observed many times in the ConsumerGroupTests that an
unbalanced consumer consumes all messages and and some type of assertion
that expects at least all members to consume some records fails by way
of timing out.

(cherry picked from commit c912d69)
  • Loading branch information
Rob Blafford authored and vbotbuildovich committed Jan 24, 2024
1 parent 5927874 commit e94a7da
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tests/rptest/tests/consumer_group_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ def create_consumers(self,

def group_is_ready():
gr = rpk.group_describe(group=group, summary=True)
return gr.members == consumer_count
return gr.members == consumer_count and gr.state == "Stable"

wait_until(group_is_ready, 60, 1)
return consumers
Expand Down

0 comments on commit e94a7da

Please sign in to comment.