From e5916eb3053699226b7c5b871ec4c4335c94ce16 Mon Sep 17 00:00:00 2001
From: pricelees <priceelees@gmail.com>
Date: Fri, 27 Jun 2025 16:08:45 +0900
Subject: [PATCH] =?UTF-8?q?refactor:=20'=EC=97=B0=EC=86=8D'=20=ED=8C=90?=
 =?UTF-8?q?=EB=8B=A8=EC=9D=84=20=EC=9C=84=ED=95=B4=20=EB=B9=84=EC=96=B4?=
 =?UTF-8?q?=EC=9E=88=EC=A7=80=20=EC=95=8A=EC=9D=80=20=EB=A0=88=EC=BD=94?=
 =?UTF-8?q?=EB=93=9C=EB=A5=BC=20=EC=9E=85=EB=A0=A5=EB=B0=9B=EB=8A=94=20?=
 =?UTF-8?q?=EA=B2=BD=EC=9A=B0=20count=EB=A5=BC=200=EC=9C=BC=EB=A1=9C=20?=
 =?UTF-8?q?=EC=84=A4=EC=A0=95=ED=95=98=EB=8F=84=EB=A1=9D=20=EA=B8=B0?=
 =?UTF-8?q?=EB=8A=A5=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../infrastructure/kafka/consumer/RecordProcessor.java      | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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<String, TestRecord> 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);
 	}
 }