From 495984d5f2dbae491c087f6692b23cab3e5b0584 Mon Sep 17 00:00:00 2001
From: Surabhi <surabhi.mahawar@aurigait.com>
Date: Tue, 15 Feb 2022 21:43:30 +0530
Subject: [PATCH] issue with campaign consume - commented the consumption

---
 .../java/com/uci/orchestrator/Consumer/CampaignConsumer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java b/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java
index b79afeb..112315a 100644
--- a/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java
+++ b/src/main/java/com/uci/orchestrator/Consumer/CampaignConsumer.java
@@ -33,7 +33,7 @@ public class CampaignConsumer {
     @Autowired
     private CampaignService campaignService;
 
-    @KafkaListener(id = "${campaign}", topics = "${campaign}")
+    // @KafkaListener(id = "${campaign}", topics = "${campaign}")
     public void consumeMessage(String campaignID) throws Exception {
         log.info("CampaignID {}", campaignID);
         processMessage(campaignID)