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<TopicPartition, ConcurrentNavigableMap<Long, EventBatch>> all; // TopicPartition + Long offset represents the SinkRecord
     private AtomicLong total;
     private ConcurrentLinkedQueue<EventBatch> failed;