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 index 5aee7b2..34c60dc 100644 --- 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 { (_, offset) -> offsetMetadata(offset) }