diff --git a/tests/rptest/tests/consumer_group_test.py b/tests/rptest/tests/consumer_group_test.py index fa0e3e8777a8..f2ece89faba5 100644 --- a/tests/rptest/tests/consumer_group_test.py +++ b/tests/rptest/tests/consumer_group_test.py @@ -10,7 +10,7 @@ from rptest.services.cluster import cluster -from rptest.clients.rpk import RpkTool +from rptest.clients.rpk import RpkException, RpkTool from rptest.clients.types import TopicSpec from rptest.services.kafka_cli_consumer import KafkaCliConsumer from rptest.services.redpanda import RESTART_LOG_ALLOW_LIST @@ -377,9 +377,13 @@ def group_is_empty(): rpk.delete_topic(self.topic_spec.name) def group_is_dead(): - rpk_group = rpk.group_describe(group) - - return rpk_group.members == 0 and rpk_group.state == "Dead" + try: + rpk_group = rpk.group_describe(group) + return rpk_group.members == 0 and rpk_group.state == "Dead" + except RpkException as e: + # allow RPK to throw an exception as redpanda nodes were + # restarted and the request may require a retry + return False wait_until(group_is_dead, 30, 2) self.producer.wait()