Skip to content

Commit 91a0730

Browse files
committed
Remove messaging header normalization
1 parent a02f88e commit 91a0730

File tree

1 file changed

+12
-4
lines changed
  • instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal

1 file changed

+12
-4
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-0.11/testing/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaClientBaseTest.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -264,10 +264,18 @@ protected static List<AttributeAssertion> processAttributes(
264264
MESSAGING_MESSAGE_BODY_SIZE, messageValue.getBytes(StandardCharsets.UTF_8).length));
265265
}
266266
if (testHeaders) {
267-
assertions.add(
268-
equalTo(
269-
AttributeKey.stringArrayKey("messaging.header.Test-Message-Header"),
270-
Collections.singletonList("test")));
267+
if (SemconvStability.isEmitOldMessageSemconv()) {
268+
assertions.add(
269+
equalTo(
270+
AttributeKey.stringArrayKey("messaging.header.Test_Message_Header"),
271+
Collections.singletonList("test")));
272+
}
273+
if (SemconvStability.isEmitStableMessageSemconv()) {
274+
assertions.add(
275+
equalTo(
276+
AttributeKey.stringArrayKey("messaging.header.Test-Message-Header"),
277+
Collections.singletonList("test")));
278+
}
271279
}
272280

273281
if (testMultiBaggage) {

0 commit comments

Comments
 (0)