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 index 2c76cd09..b7096e1d 100644 --- 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()) } } }