feat: add kafkajs instrumentation

Author: basti1302

package-lock.json

@@ -58,6 +58,7 @@
     "@opentelemetry/exporter-logs-otlp-proto": "^0.52.1",
     "@opentelemetry/exporter-metrics-otlp-proto": "^0.52.1",
     "@opentelemetry/exporter-trace-otlp-proto": "^0.52.1",
+    "@opentelemetry/instrumentation-kafkajs": "^0.1.0",
     "@opentelemetry/resource-detector-container": "^0.3.11",
     "@opentelemetry/resources": "^1.25.1",
     "@opentelemetry/sdk-logs": "^0.52.1",

package.json

@@ -13,6 +13,7 @@ import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics';
 import { NodeSDK, NodeSDKConfiguration } from '@opentelemetry/sdk-node';
 import { BatchSpanProcessor, SpanProcessor } from '@opentelemetry/sdk-trace-base';
 import { ConsoleSpanExporter } from '@opentelemetry/sdk-trace-node';
+import { KafkaJsInstrumentation } from '@opentelemetry/instrumentation-kafkajs';
 
 import PodUidDetector from './detectors/node/opentelemetry-resource-detector-kubernetes-pod';
 import ServiceNameFallbackDetector from './detectors/node/opentelemetry-resource-detector-service-name-fallback';
@@ -63,7 +64,11 @@ const configuration: Partial<NodeSDKConfiguration> = {
   spanProcessors: spanProcessors(),
   metricReader: metricsReader(),
   logRecordProcessor: logRecordProcessor(),
-  instrumentations: [getNodeAutoInstrumentations(createInstrumentationConfig())],
+  instrumentations: [
+    //
+    getNodeAutoInstrumentations(createInstrumentationConfig()),
+    new KafkaJsInstrumentation(),
+  ],
   resource: resource(),
   resourceDetectors: resourceDetectors(),
 };