hotfix: auto commit false

Saicasm · May 12, 2024 · bd865f5 · bd865f5
1 parent c41ee59
commit bd865f5
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);
     }