diff --git a/mockafka/aiokafka/aiokafka_consumer.py b/mockafka/aiokafka/aiokafka_consumer.py
index ca8a677..c83a0ce 100644
--- a/mockafka/aiokafka/aiokafka_consumer.py
+++ b/mockafka/aiokafka/aiokafka_consumer.py
@@ -112,7 +112,7 @@ async def commit(self):
         self.consumer_store = {}
 
     async def topics(self) -> set[str]:
-        return set(self.subscribed_topic)
+        return set(self.kafka.topic_list())
 
     def subscribe(
             self,