Bugfix

navikt · Jan 15, 2024 · b3c1ffa · b3c1ffa
1 parent 778912f
commit b3c1ffa
Showing 1 changed file 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
@@ -72,8 +72,8 @@ class PersonhendelseListener(
         assignments.keys.stream()
             .filter { it.topic() == "leesah-v1" }
             .forEach {
-                //callback.seekToEnd("aapen-person-pdl-leesah-v1", it.partition())
-                callback.seekToBeginning("aapen-person-pdl-leesah-v1", it.partition())
+                //callback.seekToEnd("leesah-v1", it.partition())
+                callback.seekToBeginning("leesah-v1", it.partition())
             }
     }
 }