Logg antall ganger en melding på kafka er forsøkt lest

navikt · Aug 6, 2024 · 33f3583 · 33f3583
1 parent 9dd5659
commit 33f3583
Showing 1 changed file with 6 additions and 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
@@ -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())
             }
         }