[Hot Fix] - kafka consume count increase

samagra-comms · Jun 6, 2023 · 88aa6e8 · 88aa6e8
1 parent e02425c
commit 88aa6e8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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);
     }