Prøver å lese fra start ved å endre group id og sette auto offset til…

… earliest
navikt · Jan 15, 2024 · f07c563 · f07c563
1 parent b9c25e6
commit f07c563
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/kotlin/no/nav/familie/ef/personhendelse/kafka/PersonhendelseListener.kt b/src/main/kotlin/no/nav/familie/ef/personhendelse/kafka/PersonhendelseListener.kt
@@ -29,7 +29,7 @@ class PersonhendelseListener(
 
     @KafkaListener(
         id = "familie-ef-personhendelse-aiven",
-        groupId = "familie-ef-personhendelse-leesah-1",
+        groupId = "familie-ef-personhendelse-leesah-2",
         topics = ["pdl.leesah-v1"],
         containerFactory = "kafkaAivenPersonhendelseListenerContainerFactory",
     )

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
@@ -49,7 +49,7 @@ spring:
       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
       value-deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
       max-poll-records: 1
-      auto-offset-reset: latest
+      auto-offset-reset: earliest
       enable-auto-commit: false
 
 no.nav.security.jwt: