From 88aa6e8ba96f15554caf123066e757325a431115 Mon Sep 17 00:00:00 2001
From: pankajjangid05 <pankaj.jangid@aurigait.com>
Date: Tue, 6 Jun 2023 15:35:30 +0530
Subject: [PATCH] [Hot Fix] - kafka consume count increase

---
 .../com/uci/outbound/consumers/NotificationConsumerReactive.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java b/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java
index cf8baa2..902758d 100644
--- a/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java
+++ b/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java
@@ -65,6 +65,7 @@ public void onMessage() {
     }
 
     private void logMessage(ReceiverRecord<String, String> msg) {
+        consumeCount++;
         log.info("NotificationConsumerReactive:Notification topic consume from kafka: " + consumeCount);
     }