Skip to content

Commit

Permalink
b - Feilretting av offset
Browse files Browse the repository at this point in the history
  • Loading branch information
dskarpas committed Oct 2, 2023
1 parent f5a1625 commit 59c8f9f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ class SedListenerAdresse(
@PostConstruct
fun initMetrics() {
adresseMetric = metricsHelper.init("consumeIncomingSedForAddress")
}
}x

@KafkaListener(
containerFactory = "sedKafkaListenerContainerFactory",
Expand All @@ -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()}")
}
Expand Down

0 comments on commit 59c8f9f

Please sign in to comment.