rptest: use delete.retention.ms in KafkaCliTools.create_topic()

redpanda-data · Nov 21, 2024 · 564a424 · 564a424
1 parent 2f1d113
commit 564a424
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tests/rptest/clients/kafka_cli_tools.py b/tests/rptest/clients/kafka_cli_tools.py
@@ -152,6 +152,10 @@ def create_topic(self, spec: TopicSpec):
             args += ["--config", f"retention.ms={spec.retention_ms}"]
         if spec.max_message_bytes:
             args += ["--config", f"max.message.bytes={spec.max_message_bytes}"]
+        if spec.delete_retention_ms:
+            args += [
+                "--config", f"delete.retention.ms={spec.delete_retention_ms}"
+            ]
         return self._run("kafka-topics.sh", args, desc="create_topic")
 
     def create_topic_partitions(self, topic: str, partitions: int):