From 59c8f9f2cbdec3194b286be4c16558c359b9c676 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Daniel=20Skarp=C3=A5s?= Date: Mon, 2 Oct 2023 14:59:48 +0200 Subject: [PATCH] b - Feilretting av offset --- .../pensjon/pdl/adresseoppdatering/SedListenerAdresse.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/no/nav/eessi/pensjon/pdl/adresseoppdatering/SedListenerAdresse.kt b/src/main/kotlin/no/nav/eessi/pensjon/pdl/adresseoppdatering/SedListenerAdresse.kt index 454178ec..4d4e0367 100644 --- a/src/main/kotlin/no/nav/eessi/pensjon/pdl/adresseoppdatering/SedListenerAdresse.kt +++ b/src/main/kotlin/no/nav/eessi/pensjon/pdl/adresseoppdatering/SedListenerAdresse.kt @@ -28,7 +28,7 @@ class SedListenerAdresse( @PostConstruct fun initMetrics() { adresseMetric = metricsHelper.init("consumeIncomingSedForAddress") - } + }x @KafkaListener( containerFactory = "sedKafkaListenerContainerFactory", @@ -40,7 +40,7 @@ class SedListenerAdresse( adresseMetric.measure { logger.info("SED-hendelse mottatt i partisjon: ${cr.partition()}, med offset: ${cr.offset()} ") - val offsetToSkip = listOf(541905L, 542460L, 542499L, 608449L, 613092L, 656516L, 661893L, 669811L, 684654L, 707185L, 707189L, 707190L, 712659L) + val offsetToSkip = listOf(541905L, 542460L, 542499L, 608449L, 613092L, 656516L, 661893L, 669811L, 684654L, 707185L, 707189L, 707190L, 712659L, 712660L) if (cr.offset() in offsetToSkip) { logger.warn("Hopper over offset: ${cr.offset()}") }