kafka broker should create topics with multiple partitions.

Closes-Bug:1665473 Change-Id: Iaf752fbc70acdf0a39efa8c9dd793af61c771f3a
Juniper · Feb 16, 2017 · 46ca3a4 · 46ca3a4
1 parent e2b9119
commit 46ca3a4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/contrail_provisioning/database/setup.py b/contrail_provisioning/database/setup.py
@@ -157,7 +157,9 @@ def fixup_kafka_server_properties(self, listen_ip):
         self.replace_in_file(KAFKA_SERVER_PROPERTIES, '#advertised.host.name=<hostname routable by clients>',\
                 'advertised.host.name='+listen_ip)
 
-        #Set retention policy
+        #Set partitioning and retention policy
+        self.replace_in_file(KAFKA_SERVER_PROPERTIES, 'num.partitions=.*',
+                'num.partitions=30')
         self.replace_in_file(KAFKA_SERVER_PROPERTIES, '#log.retention.bytes=.*',
                 'log.retention.bytes=1073741824')
         self.replace_in_file(KAFKA_SERVER_PROPERTIES, 'log.retention.bytes=.*',