From 33f3583b0009bc79ce0b28a27a45d01bd99326b7 Mon Sep 17 00:00:00 2001 From: Ole Christian Kvernberg Date: Tue, 6 Aug 2024 10:48:56 +0200 Subject: [PATCH] =?UTF-8?q?Logg=20antall=20ganger=20en=20melding=20p=C3=A5?= =?UTF-8?q?=20kafka=20er=20fors=C3=B8kt=20lest?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kotlin/no/nav/familie/kafka/KafkaErrorHandler.kt | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/kafka/src/main/kotlin/no/nav/familie/kafka/KafkaErrorHandler.kt b/kafka/src/main/kotlin/no/nav/familie/kafka/KafkaErrorHandler.kt index 16056022..4897a8f9 100644 --- a/kafka/src/main/kotlin/no/nav/familie/kafka/KafkaErrorHandler.kt +++ b/kafka/src/main/kotlin/no/nav/familie/kafka/KafkaErrorHandler.kt @@ -28,15 +28,18 @@ class KafkaErrorHandler(private val taskScheduler: TaskScheduler) : CommonContai container: MessageListenerContainer, ) { if (records.isEmpty()) { - logger.error("Feil ved konsumering av melding. Ingen records. ${consumer.subscription()}", e) + logger.error( + "Feil ved konsumering av melding. Ingen records. ${consumer.subscription()} (Forsøk nr ${counter.getAndAdd(1)})", + e, + ) scheduleRestart(e, records, consumer, container, "Ukjent topic") } else { records.first().run { logger.error( "Feil ved konsumering av melding fra ${this.topic()}. id ${this.key()}, " + - "offset: ${this.offset()}, partition: ${this.partition()}", + "offset: ${this.offset()}, partition: ${this.partition()} (Forsøk nr ${counter.getAndAdd(1)})", ) - secureLogger.error("${this.topic()} - Problemer med prosessering av $records", e) + secureLogger.error("${this.topic()} - Problemer med prosessering av $records (Forsøk nr ${counter.getAndAdd(1)})", e) scheduleRestart(e, records, consumer, container, this.topic()) } }