<Pause and replay messages using ReactiveKafkaCons...

# stackoverflow

[user]

Pause and replay messages using ReactiveKafkaConsumer
How can I use acknowledgement.nack in reactive kafka(using Flux to pause and replay message which is not acknowledged due to an retryable error
reactiveKafkaConsumerTemplate.receive()
.filter { myFilter(it) }
.doOnNext { receiverRecord -> process(receiverRecord) }
.retryWhen(backoff(3, Duration.ofSeconds(2)).transientErrors(true))
.doOnError {
logger.error(it) { "errorMessage" }
}
.repeat()

with this...