From e94a7da212e6d44167ec7d77f3e949a1acbcd7cd Mon Sep 17 00:00:00 2001 From: Rob Blafford Date: Wed, 17 Jan 2024 10:58:48 -0500 Subject: [PATCH] rptest: Wait for Stable before start cgrups tests - 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 c912d694b9a6ebe501ead0a2381ab3f891cc34a2) --- tests/rptest/tests/consumer_group_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/rptest/tests/consumer_group_test.py b/tests/rptest/tests/consumer_group_test.py index 9075666e2bd68..06ed83f6ab51f 100644 --- a/tests/rptest/tests/consumer_group_test.py +++ b/tests/rptest/tests/consumer_group_test.py @@ -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