Log average and max size

Author: emasab

ci/tests/run_perf_test.js

@@ -72,6 +72,7 @@ const consumerConfluentBatchMaxLatency = extractValue(outputConfluentProducerCon
 const consumerConfluentBatchTime = extractValue(outputConfluentProducerConsumer, '=== Consumption time (eachBatch):');
 const consumerConfluentBatchAverageLag = extractValue(outputConfluentProducerConsumer, '=== Average eachBatch lag:');
 const consumerConfluentBatchMaxLag = extractValue(outputConfluentProducerConsumer, '=== Max eachBatch lag:');
+const consumerConfluentBatchAverageSize = extractValue(outputConfluentProducerConsumer, '=== Average eachBatch size:');
 const consumerConfluentAverageRSS = extractValue(outputConfluentProducerConsumer, '=== Max Average RSS across tests:');
 const consumerConfluentMaxRSS = extractValue(outputConfluentProducerConsumer, '=== Max RSS across tests:');
 if (!skipCtpTest) {
@@ -92,6 +93,7 @@ const consumerKjsBatchMaxLatency = extractValue(outputKjsProducerConsumer, '===
 const consumerKjsBatchTime = extractValue(outputKjsProducerConsumer, '=== Consumption time (eachBatch):');
 const consumerKjsBatchAverageLag = extractValue(outputKjsProducerConsumer, '=== Average eachBatch lag:');
 const consumerKjsBatchMaxLag = extractValue(outputKjsProducerConsumer, '=== Max eachBatch lag:');
+const consumerKjsBatchAverageSize = extractValue(outputKjsProducerConsumer, '=== Average eachBatch size:');
 const consumerKjsAverageRSS = extractValue(outputKjsProducerConsumer, '=== Max Average RSS across tests:');
 const consumerKjsMaxRSS = extractValue(outputKjsProducerConsumer, '=== Max RSS across tests:');
 if (!skipCtpTest) {
@@ -112,6 +114,7 @@ console.log(`Consumer max E2E latency (eachBatch): confluent ${consumerConfluent
 console.log(`Consumption time (eachBatch): confluent ${consumerConfluentBatchTime}, kafkajs ${consumerKjsBatchTime}`);
 console.log(`Average eachBatch lag: confluent ${consumerConfluentBatchAverageLag}, kafkajs ${consumerKjsBatchAverageLag}`);
 console.log(`Max eachBatch lag: confluent ${consumerConfluentBatchMaxLag}, kafkajs ${consumerKjsBatchMaxLag}`);
+console.log(`Average eachBatch size: confluent ${consumerConfluentBatchAverageSize}, kafkajs ${consumerKjsBatchAverageSize}`);
 console.log(`Average RSS: confluent ${consumerConfluentAverageRSS}, kafkajs ${consumerKjsAverageRSS}`);
 console.log(`Max RSS: confluent ${consumerConfluentMaxRSS}, kafkajs ${consumerKjsMaxRSS}`);
 if (!skipCtpTest) {

examples/performance/performance-primitives-common.js

@@ -23,7 +23,7 @@ async function runConsumer(consumer, topic, warmupMessages, totalMessageCnt, eac
         const sentAt = Number(decoder.decode(message.value.slice(0, 13)));
         const latency = receivedAt - sentAt;
 
-        if (stats.maxLatency === undefined) {
+        if (!stats.maxLatency) {
             stats.maxLatency = latency;
             stats.avgLatency = latency;
         } else {

examples/performance/performance-primitives-kafkajs.js

@@ -70,7 +70,7 @@ async function runProducer(parameters, topic, batchSize, warmupMessages, totalMe
     let staticValueLength = Math.floor(msgSize * (1 - randomness));
     if (staticValueLength < 13)
         staticValueLength = 13;
-    const staticValueRemainder = staticValueLength - 13;
+    let staticValueRemainder = staticValueLength - 13;
     if (staticValueRemainder > 0) {
         staticValueRemainder = randomBytes(staticValueRemainder);
     } else {

examples/performance/performance-primitives.js

@@ -69,7 +69,7 @@ async function runProducer(parameters, topic, batchSize, warmupMessages, totalMe
     let staticValueLength = Math.floor(msgSize * (1 - randomness));
     if (staticValueLength < 13)
         staticValueLength = 13;
-    const staticValueRemainder = staticValueLength - 13;
+    let staticValueRemainder = staticValueLength - 13;
     if (staticValueRemainder > 0) {
         staticValueRemainder = randomBytes(staticValueRemainder);
     } else {