change how topics are listed via cmd line

wbarnha · Aug 8, 2024 · 34a36ab · 34a36ab
1 parent 6175155
commit 34a36ab
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/test/fixtures.py b/test/fixtures.py
@@ -612,9 +612,8 @@ def _create_topic_via_cli(self, topic_name, num_partitions, replication_factor):
 
     def get_topic_names(self):
         args = self.kafka_run_class_args('kafka.admin.TopicCommand',
-                                         '--zookeeper', '%s:%s/%s' % (self.zookeeper.host,
-                                                                      self.zookeeper.port,
-                                                                      self.zk_chroot),
+                                         '--bootstrap-server',
+                                         '%s:%s' % (self.host, self.port),
                                          '--list'
                                          )
         env = self.kafka_run_class_env()