test: resolved flaky rdkafka tests (#2001)

ref https://jsw.ibm.com/browse/INSTA-41047

Author: aryamohanan

packages/collector/test/tracing/messaging/node-rdkafka/consumer.js

@@ -97,9 +97,8 @@ function setupConsumer() {
       span.end();
     });
   } else {
-    _consumer = new Kafka.KafkaConsumer(consumerOptions, {
-      'auto.offset.reset': 'earliest'
-    });
+    _consumer = new Kafka.KafkaConsumer(consumerOptions);
+
     _consumer.connect();
 
     _consumer.on('ready', () => {

packages/collector/test/tracing/messaging/node-rdkafka/producer.js

@@ -21,6 +21,7 @@ const express = require('express');
 const port = require('../../../test_util/app-port')();
 const enableDeliveryCb = process.env.RDKAFKA_PRODUCER_DELIVERY_CB === 'true';
 const isStream = process.env.RDKAFKA_PRODUCER_AS_STREAM === 'true';
+
 const app = express();
 const topic = 'rdkafka-topic';
 let throwDeliveryErr = false;
@@ -113,6 +114,8 @@ let messageCounter = 0;
 const producer = getProducer();
 
 /**
+ * @param {boolean} bufferErrorSender
+ * @param {string} method
  * @param {string} msg
  * @returns {{ wasSent: boolean, topic: string, msg: string, timestamp: number }}
  */
@@ -175,25 +178,22 @@ function doProduce(bufferErrorSender = false, method, msg = 'Node rdkafka is gre
 
       log('Sending message as standard on topic', topic);
 
-      setTimeout(() => {
-        const wasSent = producer.produce(topic, null, theMessage, null, null, null, [
-          { message_counter: ++messageCounter }
-        ]);
-
-        log('Sent message as standard', wasSent);
-
-        setTimeout(async () => {
-          await fetch(`http://127.0.0.1:${agentPort}`);
-
-          resolve({
-            timestamp: Date.now(),
-            wasSent,
-            topic,
-            msg: theMessage,
-            messageCounter
-          });
-        }, 100);
-      }, 2 * 1000);
+      const wasSent = producer.produce(topic, null, theMessage, null, null, null, [
+        { message_counter: ++messageCounter }
+      ]);
+
+      log('Sent message as standard', wasSent);
+
+      setTimeout(async () => {
+        await fetch(`http://127.0.0.1:${agentPort}`);
+        resolve({
+          timestamp: Date.now(),
+          wasSent,
+          topic,
+          msg: theMessage,
+          messageCounter
+        });
+      }, 100);
     });
   }
 }

packages/collector/test/tracing/messaging/node-rdkafka/test.js

@@ -58,8 +58,7 @@ const topic = 'rdkafka-topic';
 
 const mochaSuiteFn = supportedVersion(process.versions.node) ? describe : describe.skip;
 
-// TODO: enable again. Its very flaky
-mochaSuiteFn.skip('tracing/messaging/node-rdkafka', function () {
+mochaSuiteFn('tracing/messaging/node-rdkafka', function () {
   this.timeout(config.getTestTimeout() * 10);
 
   globalAgent.setUpCleanUpHooks();