From 386cdb95e797b3315ba2eab5b8449c4ac71e96ee Mon Sep 17 00:00:00 2001 From: Tom Date: Thu, 23 Nov 2023 00:49:39 -0800 Subject: [PATCH] Fixes minor typo in kafka emitter (#15416) --- .../java/org/apache/druid/emitter/kafka/KafkaEmitter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java b/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java index dd8f3665f537..4a58464f7308 100644 --- a/extensions-contrib/kafka-emitter/src/main/java/org/apache/druid/emitter/kafka/KafkaEmitter.java +++ b/extensions-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(); } }; }