diff --git a/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/RecordProcessor.java b/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/RecordProcessor.java index bb4562a..42718ce 100644 --- a/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/RecordProcessor.java +++ b/src/main/java/com/sangdol/consumer/infrastructure/kafka/consumer/RecordProcessor.java @@ -22,7 +22,7 @@ public class RecordProcessor { private long initialRecordReceivedTime = 0; public void process(ConsumerRecords records) throws Exception { - initializeTime(); + preProcess(); log.debug("[RecordProcessor] process {} records. thread: {}", records.count(), Thread.currentThread().getName()); @@ -50,9 +50,11 @@ public class RecordProcessor { } } - private void initializeTime() { + private void preProcess() { if (initialRecordReceivedTime == 0) { initialRecordReceivedTime = System.currentTimeMillis(); } + + emptyPollResultCount.set(0); } }