tracing: add support for @confluentinc/kafka-javascript (#5489)

Author: wconti27

.github/workflows/plugins.yml

@@ -245,6 +245,47 @@ jobs:
       - run: yarn test:plugins:ci
       - uses: codecov/codecov-action@ad3126e916f78f00edff4ed0317cf185271ccc2d # v5.4.2
 
+  confluentinc-kafka-javascript:
+    strategy:
+      matrix:
+        # using node versions matrix since this plugin testing fails due to install differences between node versions
+        node-version: ['18', '20', '22']
+    runs-on: ubuntu-latest
+    services:
+      kafka:
+        image: apache/kafka-native:3.8.0-rc2
+        env:
+          KAFKA_PROCESS_ROLES: broker,controller
+          KAFKA_NODE_ID: '1'
+          KAFKA_LISTENERS: PLAINTEXT://:9092,CONTROLLER://:9093
+          KAFKA_CONTROLLER_QUORUM_VOTERS: 1@127.0.0.1:9093
+          KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
+          KAFKA_CLUSTER_ID: r4zt_wrqTRuT7W2NJsB_GA
+          KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://127.0.0.1:9092
+          KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
+          KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
+          KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: '1'
+          KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: '0'
+        ports:
+          - 9092:9092
+          - 9093:9093
+    env:
+      PLUGINS: confluentinc-kafka-javascript
+      SERVICES: kafka
+    steps:
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
+      - uses: ./.github/actions/testagent/start
+      - uses: actions/setup-node@1d0ff469b7ec7b3cb9d8673fde0c81c44821de2a # v4.2.0
+        with:
+          node-version: ${{ matrix.node-version }}
+      - uses: ./.github/actions/install
+      - run: yarn test:plugins:ci
+      - if: always()
+        uses: ./.github/actions/testagent/logs
+        with:
+          suffix: plugins-${{ github.job }}-${{ matrix.node-version }}
+      - uses: codecov/codecov-action@13ce06bfc6bbe3ecf90edbbf1bc32fe5978ca1d3 # v5.3.1
+
   cookie-parser:
     runs-on: ubuntu-latest
     env:

.github/workflows/system-tests.yml

@@ -31,7 +31,7 @@ jobs:
     uses: DataDog/system-tests/.github/workflows/compute-workflow-parameters.yml@main
     with:
       library: nodejs
-      scenarios_groups: essentials,appsec_rasp,debugger
+      scenarios_groups: essentials,appsec_rasp,debugger,integrations
 
   system-tests:
     runs-on: ${{ contains(fromJSON('["CROSSED_TRACING_LIBRARIES", "INTEGRATIONS"]'), matrix.scenario) && 'ubuntu-latest-16-cores' || 'ubuntu-latest' }}

docs/API.md

@@ -30,6 +30,7 @@ tracer.use('pg', {
 <h5 id="aws-sdk-config"></h5>
 <h5 id="azure-functions"></h5>
 <h5 id="bunyan"></h5>
+<h5 id="confluentinc-kafka-javascript"></h5>
 <h5 id="couchbase"></h5>
 <h5 id="cucumber"></h5>
 <h5 id="dns"></h5>
@@ -111,6 +112,7 @@ tracer.use('pg', {
 * [couchbase](./interfaces/export_.plugins.couchbase.html)
 * [cucumber](./interfaces/export_.plugins.cucumber.html)
 * [bunyan](./interfaces/export_.plugins.bunyan.html)
+* [confluentinc-kafka-javascript](./interfaces/export_.plugins.confluentinc_kafka_javascript.html)
 * [cassandra-driver](./interfaces/export_.plugins.cassandra_driver.html)
 * [connect](./interfaces/export_.plugins.connect.html)
 * [dns](./interfaces/export_.plugins.dns.html)

docs/add-redirects.sh

@@ -21,6 +21,7 @@ declare -a plugins=(
   "cucumber"
   "bunyan"
   "cassandra_driver"
+  "confluentinc_kafka_javascript"
   "connect"
   "dns"
   "elasticsearch"

docs/test.ts

@@ -296,6 +296,7 @@ tracer.use('bunyan');
 tracer.use('couchbase');
 tracer.use('cassandra-driver');
 tracer.use('child_process');
+tracer.use('confluentinc-kafka-javascript');
 tracer.use('connect');
 tracer.use('connect', httpServerOptions);
 tracer.use('cypress');

index.d.ts

@@ -154,6 +154,7 @@ interface Plugins {
   "bunyan": tracer.plugins.bunyan;
   "cassandra-driver": tracer.plugins.cassandra_driver;
   "child_process": tracer.plugins.child_process;
+  "confluentinc-kafka-javascript": tracer.plugins.confluentinc_kafka_javascript;
   "connect": tracer.plugins.connect;
   "couchbase": tracer.plugins.couchbase;
   "cucumber": tracer.plugins.cucumber;
@@ -1344,6 +1345,12 @@ declare namespace tracer {
      * [child_process](https://nodejs.org/api/child_process.html) module.
      */
     interface child_process extends Instrumentation {}
+  
+    /**
+     * This plugin automatically instruments the
+     * [confluentinc-kafka-javascript](https://github.com/confluentinc/confluent-kafka-js) module.
+     */
+    interface confluentinc_kafka_javascript extends Instrumentation {}
 
     /**
      * This plugin automatically instruments the