Fixes minor typo in kafka emitter (#15416)

apache · Nov 23, 2023 · 386cdb9 · 386cdb9
1 parent c14cfc2
commit 386cdb9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java b/...ions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java
@@ -92,12 +92,12 @@ public KafkaEmitter(KafkaEmitterConfig config, ObjectMapper jsonMapper)
     this.invalidLost = new AtomicLong(0L);
   }
 
-  private Callback setProducerCallback(AtomicLong lostCouter)
+  private Callback setProducerCallback(AtomicLong lostCounter)
   {
     return (recordMetadata, e) -> {
       if (e != null) {
         log.debug("Event send failed [%s]", e.getMessage());
-        lostCouter.incrementAndGet();
+        lostCounter.incrementAndGet();
       }
     };
   }