up

Author: trask

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaConsumerTelemetrySupplier.java

@@ -19,6 +19,8 @@
 public class KafkaConsumerTelemetrySupplier
     implements Supplier<KafkaConsumerTelemetry>, Serializable {
 
+  private static final long serialVersionUID = 1L;
+
   private final KafkaConsumerTelemetry consumerTelemetry;
 
   public KafkaConsumerTelemetrySupplier(KafkaConsumerTelemetry consumerTelemetry) {
@@ -30,11 +32,8 @@ public KafkaConsumerTelemetry get() {
     return consumerTelemetry;
   }
 
-  /**
-   * Replaces this object with null in the serialization stream. This ensures the supplier does not
-   * get serialized.
-   */
   private Object writeReplace() {
+    // serialize this object to null
     return null;
   }
 }

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaProducerTelemetrySupplier.java

@@ -19,6 +19,8 @@
 public class KafkaProducerTelemetrySupplier
     implements Supplier<KafkaProducerTelemetry>, Serializable {
 
+  private static final long serialVersionUID = 1L;
+
   private final KafkaProducerTelemetry producerTelemetry;
 
   public KafkaProducerTelemetrySupplier(KafkaProducerTelemetry producerTelemetry) {
@@ -30,11 +32,8 @@ public KafkaProducerTelemetry get() {
     return producerTelemetry;
   }
 
-  /**
-   * Replaces this object with null in the serialization stream. This ensures the supplier does not
-   * get serialized.
-   */
   private Object writeReplace() {
+    // serialize this object to null
     return null;
   }
 }