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);
     }