Update esque/controller/topic_controller.py

Co-authored-by: Swen Wenzel <5111028+swenzel@users.noreply.github.com>
kaufland-ecommerce · Apr 15, 2021 · 0189fb6 · 0189fb6
1 parent 107251a
commit 0189fb6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/esque/controller/topic_controller.py b/esque/controller/topic_controller.py
@@ -47,7 +47,7 @@ def list_topics(
             topic_names = sorted(topic_names)
 
         if get_topic_objects:
-            topics = [self.get_cluster_topic(topic_name, retrieve_partition_data=False) for topic_name in topic_names]
+            topics = [self.get_cluster_topic(topic_name, retrieve_partition_data=get_partitions) for topic_name in topic_names]
         else:
             topics = list(map(self.get_local_topic, topic_names))
         return topics