up

trask · trask · commit 385bc151be89 · 2025-10-10T16:31:30.000-07:00
diff --git a/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetry.java b/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/KafkaTelemetry.java
@@ -73,7 +73,6 @@ KafkaConsumerTelemetry getConsumerTelemetry() {
     return consumerTelemetry;
   }
 
-  // TODO consider if this is needed in public API
   @SuppressWarnings("unchecked")
   public <K, V> Producer<K, V> wrap(Producer<K, V> producer) {
     return (Producer<K, V>)
@@ -102,7 +101,6 @@ public <K, V> Producer<K, V> wrap(Producer<K, V> producer) {
             });
   }
 
-  // TODO consider if this is needed in public API
   @SuppressWarnings("unchecked")
   public <K, V> Consumer<K, V> wrap(Consumer<K, V> consumer) {
     return (Consumer<K, V>)

Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,6 @@ KafkaConsumerTelemetry getConsumerTelemetry() {`
`73`	`73`	`return consumerTelemetry;`
`74`	`74`	`}`
`75`	`75`
`76`		`- // TODO consider if this is needed in public API`
`77`	`76`	`@SuppressWarnings("unchecked")`
`78`	`77`	`public <K, V> Producer<K, V> wrap(Producer<K, V> producer) {`
`79`	`78`	`return (Producer<K, V>)`
`@@ -102,7 +101,6 @@ public <K, V> Producer<K, V> wrap(Producer<K, V> producer) {`
`102`	`101`	`});`
`103`	`102`	`}`
`104`	`103`
`105`		`- // TODO consider if this is needed in public API`
`106`	`104`	`@SuppressWarnings("unchecked")`
`107`	`105`	`public <K, V> Consumer<K, V> wrap(Consumer<K, V> consumer) {`
`108`	`106`	`return (Consumer<K, V>)`