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...