changes

goafabric · Jul 6, 2024 · 9da7268 · 9da7268
1 parent c8fcdd7
commit 9da7268
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/java/org/goafabric/eventdispatcher/consumer/kafka/CalendarConsumer.java b/src/main/java/org/goafabric/eventdispatcher/consumer/kafka/CalendarConsumer.java
@@ -14,8 +14,7 @@ public class CalendarConsumer {
 
     static final String CONSUMER_NAME = "Calendar";
 
-    @KafkaListener(groupId = CONSUMER_NAME, topics = "patient")
-    @KafkaListener(groupId = CONSUMER_NAME, topics = "practitioner")
+    @KafkaListener(groupId = CONSUMER_NAME, topics = {"patient", "practitioner"})
     public void processKafka(@Header(KafkaHeaders.RECEIVED_KEY) String key, EventData eventData) {
         process(key, eventData);
     }