kafka changes

goafabric · Jul 5, 2024 · 1a7d253 · 1a7d253
1 parent ca345af
commit 1a7d253
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 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,8 @@ public class CalendarConsumer {
 
     static final String CONSUMER_NAME = "Calendar";
 
-    @KafkaListener(groupId = CONSUMER_NAME,
-            topics = {"patient.create", "patient.update", "preactitioner.create", "practitioner.update"})
+    @KafkaListener(groupId = CONSUMER_NAME, topics = {"patient.create", "patient.update"})
+    @KafkaListener(groupId = CONSUMER_NAME, topics = {"practitioner.create", "practitioner.update"})
     public void processKafka(@Header(KafkaHeaders.RECEIVED_TOPIC) String key, EventData eventData) {
         process(key, eventData);
     }

diff --git a/src/main/java/org/goafabric/eventdispatcher/producer/EventProducerKafka.java b/src/main/java/org/goafabric/eventdispatcher/producer/EventProducerKafka.java
@@ -27,8 +27,8 @@ public void produce(ChangeEvent changeEvent) {
                 changeEvent.referenceId());
     }
 
-    private void send(String key, String referenceId) {
-        kafkaTemplate.send(key, new EventData(referenceId));
+    private void send(String topic, String referenceId) {
+        kafkaTemplate.send(topic, referenceId, new EventData(referenceId));
     }
 
 }