tar bort unødvendig seek

navikt · Jan 27, 2025 · 76316f3 · 76316f3
1 parent 17a2772
commit 76316f3
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/rapids-and-rivers/src/main/kotlin/com/github/navikt/tbd_libs/rapids_and_rivers/KafkaRapid.kt b/rapids-and-rivers/src/main/kotlin/com/github/navikt/tbd_libs/rapids_and_rivers/KafkaRapid.kt
@@ -119,7 +119,6 @@ class KafkaRapid(
                         currentPositions.map { "\tpartition=${it.key}, offset=${it.value}" }
                             .joinToString(separator = "\n", prefix = "\n", postfix = "\n"), err
             )
-            currentPositions.forEach { (partition, offset) -> consumer.seek(partition, offset) }
             throw err
         } finally {
             val offsetsToBeCommitted = currentPositions.mapValues<TopicPartition, Long, OffsetAndMetadata> { (_, offset) -> offsetMetadata(offset) }