fix

wl2027 · breedx-splk · web-flow · commit 07e095d88c79 · 2025-06-17T19:49:49.000+08:00
Co-authored-by: jason plumb &lt;75337021+breedx-splk@users.noreply.github.com&gt;
diff --git a/instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaProducerAttributesExtractor.java b/instrumentation/kafka/kafka-clients/kafka-clients-common-0.11/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/common/v0_11/internal/KafkaProducerAttributesExtractor.java
@@ -40,9 +40,7 @@ public void onStart(
     }
 
     String bootstrapServers = request.getBootstrapServers();
-    if (bootstrapServers != null) {
-      attributes.put(MESSAGING_KAFKA_BOOTSTRAP_SERVERS, bootstrapServers);
-    }
+    attributes.put(MESSAGING_KAFKA_BOOTSTRAP_SERVERS, bootstrapServers);
   }
 
   private static boolean canSerialize(Class<?> keyClass) {

Original file line number	Diff line number	Diff line change
`@@ -40,9 +40,7 @@ public void onStart(`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`String bootstrapServers = request.getBootstrapServers();`
`43`		`- if (bootstrapServers != null) {`
`44`		`- attributes.put(MESSAGING_KAFKA_BOOTSTRAP_SERVERS, bootstrapServers);`
`45`		`- }`
	`43`	`+ attributes.put(MESSAGING_KAFKA_BOOTSTRAP_SERVERS, bootstrapServers);`
`46`	`44`	`}`
`47`	`45`
`48`	`46`	`private static boolean canSerialize(Class<?> keyClass) {`