Skip to content

Commit e42d441

Browse files
Merge pull request #313 from splunk/logger_inconsistency
Remove Logger inconsistency problem
2 parents c6ec2aa + 2c34eab commit e42d441

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/splunk/kafka/connect/KafkaRecordTracker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
import org.slf4j.LoggerFactory;
3434

3535
final class KafkaRecordTracker {
36-
private static final Logger log = LoggerFactory.getLogger(SplunkSinkTask.class);
36+
private static final Logger log = LoggerFactory.getLogger(KafkaRecordTracker.class);
3737
private ConcurrentMap<TopicPartition, ConcurrentNavigableMap<Long, EventBatch>> all; // TopicPartition + Long offset represents the SinkRecord
3838
private AtomicLong total;
3939
private ConcurrentLinkedQueue<EventBatch> failed;

0 commit comments

Comments
 (0)