cloudtests: testdrive: expose kafka_option (MaterializeInc#22318)

D0LLi · Oct 11, 2023 · 67c9614 · 67c9614
1 parent 57c6085
commit 67c9614
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/misc/python/materialize/cloudtest/k8s/testdrive.py b/misc/python/materialize/cloudtest/k8s/testdrive.py
@@ -45,6 +45,7 @@ def run(
         seed: int | None = None,
         caller: Traceback | None = None,
         default_timeout: str = "300s",
+        kafka_options: str | None = None,
         log_filter: str = "off",
     ) -> None:
         command: list[str] = [
@@ -66,6 +67,7 @@ def run(
             *(["--no-reset"] if no_reset else []),
             *([f"--seed={seed}"] if seed else []),
             *([f"--source={caller.filename}:{caller.lineno}"] if caller else []),
+            *([f"--kafka-option={kafka_options}"] if kafka_options else []),
             *args,
         ]