Fix

aio-libs · Nov 15, 2023 · 6178bcc · 6178bcc
1 parent fb25274
commit 6178bcc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/aiokafka/cluster.py b/aiokafka/cluster.py
@@ -56,6 +56,7 @@ def __init__(self, **configs):
         self.need_all_topic_metadata = False
         self.unauthorized_topics = set()
         self.internal_topics = set()
+        self.external_topics = set()
         self.controller = None
 
         self.config = copy.copy(self.DEFAULT_CONFIG)
@@ -193,7 +194,7 @@ def topics(self, exclude_internal_topics=True):
             set: {topic (str), ...}
         """
         if exclude_internal_topics:
-            return self.external_topics 
+            return self.external_topics
         else:
             return self._topics