Fixes

Author: emasab

ci/tests/run_perf_test.js

@@ -9,7 +9,9 @@ function runCommand(command) {
     return output;
   } catch (error) {
     const errorOutput = error.stdout || error.stderr || error.message;
-    console.log(errorOutput);
+    console.log(error.stdout);
+    console.log(error.stderr);
+    console.log(error.message);
     return errorOutput;
   }
 }
@@ -30,7 +32,7 @@ function extractValue(content, pattern) {
 
 function belowThreshold(value, target, threshold = 0.7) {
   if (isNaN(value) || isNaN(target))
-    throw new Error(`Invalid number comparison: value=${value}, target=${target}`);
+    return false;
   return value < (target * threshold);
 }
 

examples/performance/performance-primitives-common.js

@@ -57,10 +57,11 @@ async function runConsumer(consumer, topic, warmupMessages, totalMessageCnt, eac
 
                     if (!startTime) {
                         startTime = hrtime.bigint();
-                    } else if (messagesMeasured === totalMessageCnt) {
+                    } else if (messagesMeasured >= totalMessageCnt) {
                         let durationNanos = Number(hrtime.bigint() - startTime);
                         durationSeconds = durationNanos / 1e9;
-                        rate = (totalMessageSize / durationNanos) * 1e9 / (1024 * 1024); /* MB/s */
+                        rate = durationNanos === 0 ? Infinity :
+                            (totalMessageSize / durationNanos) * 1e9 / (1024 * 1024); /* MB/s */
                         console.log(`Recvd ${messagesMeasured} messages in ${durationSeconds} seconds, ${totalMessageSize} bytes; rate is ${rate} MB/s`);
                         consumer.pause([{ topic }]);
                     }

examples/performance/performance-primitives.js

@@ -22,7 +22,7 @@ function baseConfiguration(parameters) {
         ret = {
             ...ret,
             'security.protocol': parameters.securityProtocol,
-            'sasl.mechanism': 'plain',
+            'sasl.mechanism': 'PLAIN',
             'sasl.username': parameters.saslUsername,
             'sasl.password': parameters.saslPassword,
         };