diff --git a/voltha/adapters/openolt/openolt_kafka_admin.py b/voltha/adapters/openolt/openolt_kafka_admin.py
index bca17f0..fe00bb6 100644
--- a/voltha/adapters/openolt/openolt_kafka_admin.py
+++ b/voltha/adapters/openolt/openolt_kafka_admin.py
@@ -48,6 +48,9 @@
     def delete_topics(self, topics):
         kafka_delete_topics(self.admin_client, topics, timeout=0)
 
+    def create_topics(self, topics):
+        kafka_create_topics(self.admin_client, topics)
+
 
 def kafka_create_topics(a, topics):
     """ Create topics """