diff --git a/tests/rptest/tests/retention_policy_test.py b/tests/rptest/tests/retention_policy_test.py index ee30f3579795..2f4fdbe46606 100644 --- a/tests/rptest/tests/retention_policy_test.py +++ b/tests/rptest/tests/retention_policy_test.py @@ -114,6 +114,10 @@ def test_changing_topic_retention_with_restart(self): self.redpanda.restart_nodes(self.redpanda.nodes) kafka_tools = KafkaCliTools(self.redpanda) + + # Wait for controller, alter configs doesn't have a retry loop + kafka_tools.describe_topic(self.topic) + # change retention bytes to preserve 15 segments kafka_tools.alter_topic_config( self.topic, {