From 2c34eabe34175abf977baac97063c738b1c448a1 Mon Sep 17 00:00:00 2001 From: ankit-splunk Date: Tue, 21 Dec 2021 12:12:07 +0530 Subject: [PATCH] Remove Logger inconsistency problem --- src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java b/src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java index 5a554053..954348ad 100644 --- a/src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java +++ b/src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java @@ -33,7 +33,7 @@ import org.slf4j.LoggerFactory; final class KafkaRecordTracker { - private static final Logger log = LoggerFactory.getLogger(SplunkSinkTask.class); + private static final Logger log = LoggerFactory.getLogger(KafkaRecordTracker.class); private ConcurrentMap> all; // TopicPartition + Long offset represents the SinkRecord private AtomicLong total; private ConcurrentLinkedQueue failed;