| commit | 11bb9444bdd7cd9ca383447c1a0bcfe5312c0150 | [log] [tgz] |
|---|---|---|
| author | Shad Ansari <shad@opennetworking.org> | Wed Apr 17 12:35:35 2019 -0700 |
| committer | Shad Ansari <shad@opennetworking.org> | Fri May 17 05:59:38 2019 +0000 |
| tree | 2582ac2e99d84b5c4879fb5e73aa5162e34c8471 | |
| parent | 72462c840369ffa46e2419b9e19fee158e6e8088 [diff] |
Add kafka admin api to create topics Change-Id: I53613c1fb48d3294b003600dc4a2c68ff1e4d211
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 """