Skip to content

Commit

Permalink
Remove Logger inconsistency problem
Browse files Browse the repository at this point in the history
  • Loading branch information
ankit-splunk committed Dec 21, 2021
1 parent c6ec2aa commit 2c34eab
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit 2c34eab

Please sign in to comment.