Log number of partitions

Author: emasab

examples/performance/performance-consolidated.js

@@ -95,6 +95,7 @@ function logParameters(parameters) {
         logParameters(parameters);
         console.log(`  Topic: ${topic}`);
         console.log(`  Topic2: ${topic2}`);
+        console.log(`  Partitions: ${numPartitions}`);
         await runCreateTopics(parameters, topic, topic2, numPartitions);
     }
 

examples/performance/performance-primitives-kafkajs.js

@@ -43,7 +43,7 @@ async function runCreateTopics(parameters, topic, topic2, numPartitions) {
             topics: [{ topic: t, numPartitions }],
         }).catch(console.error);
         if (topicCreated) {
-            console.log(`Created topic ${t}`);
+            console.log(`Created topic ${t} with ${numPartitions} partitions`);
             continue;
         }
 
@@ -55,7 +55,7 @@ async function runCreateTopics(parameters, topic, topic2, numPartitions) {
                 { topic: t, numPartitions },
             ],
         }).catch(console.error);
-        console.log(`Created topic ${t}`);
+        console.log(`Created topic ${t} with ${numPartitions} partitions`);
     }
 
     await admin.disconnect();

examples/performance/performance-primitives.js

@@ -41,7 +41,7 @@ async function runCreateTopics(parameters, topic, topic2, numPartitions) {
             topics: [{ topic: t, numPartitions }],
         }).catch(console.error);
         if (topicCreated) {
-            console.log(`Created topic ${t}`);
+            console.log(`Created topic ${t} with ${numPartitions} partitions`);
             continue;
         }
 
@@ -53,7 +53,7 @@ async function runCreateTopics(parameters, topic, topic2, numPartitions) {
                 { topic: t, numPartitions },
             ],
         }).catch(console.error);
-        console.log(`Created topic ${t}`);
+        console.log(`Created topic ${t} with ${numPartitions} partitions`);
         await new Promise(resolve => setTimeout(resolve, 1000)); /* Propagate. */
     }