From b3c1ffa5d641b1b68627d42ea498386173b5959a Mon Sep 17 00:00:00 2001 From: Ole Christian Kvernberg Date: Mon, 15 Jan 2024 14:04:44 +0100 Subject: [PATCH] Bugfix --- .../familie/ef/personhendelse/kafka/PersonhendelseListener.kt | 4 ++-- 1 file changed, 2 insertions(+), 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 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()) } } }