fix: compare kafka header keys case insensitively

signalfx · Sep 27, 2023 · 1a2d86b · 1a2d86b
1 parent e2a6e39
commit 1a2d86b
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/src/instrumentations/external/kafkajs/kafkajs.ts b/src/instrumentations/external/kafkajs/kafkajs.ts
@@ -43,7 +43,7 @@ import type {
 } from 'kafkajs';
 import { KafkaJsInstrumentationConfig } from './types';
 import { VERSION } from '../../../version';
-import { bufferTextMapGetter } from './propagtor';
+import { bufferTextMapGetter } from './propagator';
 import {
   InstrumentationBase,
   InstrumentationModuleDefinition,

diff --git a/...umentations/external/kafkajs/propagtor.ts → ...mentations/external/kafkajs/propagator.ts b/...umentations/external/kafkajs/propagtor.ts → ...mentations/external/kafkajs/propagator.ts
@@ -22,7 +22,19 @@ adding toString() to make sure string is returned
 */
 export const bufferTextMapGetter: TextMapGetter = {
   get(carrier, key) {
-    return carrier?.[key]?.toString();
+    if (carrier === undefined) {
+      return undefined;
+    }
+
+    const keys = Object.keys(carrier);
+
+    for (const carrierKey of keys) {
+      if (carrierKey.toLowerCase() === key) {
+        return carrier[carrierKey]?.toString();
+      }
+    }
+
+    return undefined;
   },
 
   keys(carrier) {