Merge pull request #11 from Saicasm/dev

hotfix: auto commit false
Saicasm · May 12, 2024 · 4b14240 · 4b14240
2 parents 23dafed + bd865f5
commit 4b14240
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/search-details/src/main/java/io/spring/searchsp/kafka/KafkaConsumer.java b/search-details/src/main/java/io/spring/searchsp/kafka/KafkaConsumer.java
@@ -13,7 +13,9 @@ public class KafkaConsumer {
 
     private final BlockingQueue<List<MusicTrack>> responseQueue = new LinkedBlockingQueue<>();
 
-    @KafkaListener(topics = "final-recommendation", groupId = "client-group")
+    @KafkaListener(topics = "final-recommendation",
+            properties = {"enable.auto.commit:false", "auto.offset.reset:latest"},
+            groupId = "client-group")
     public void listen(@Payload List<MusicTrack> message ) {
         responseQueue.offer(message);
     }