0

I need to implement retry feature in kafka consumer. I am using spring reactor api.

Flux> inboundFlux = KafkaReceiver.create(receiverOptions).receive();

    inboundFlux.subscribe(r -> {
        if (accept(r)) {
            r.receiverOffset().acknowledge();
        }
    }, this::errorOut);

The retry option on inboundFlux.retry() is not working. Please suggest how do I make this work.

2
  • What are the symptoms that you decided it doesn’t work? Sep 28, 2018 at 19:38
  • How do I make sure it calls accept() again after retry? Oct 3, 2018 at 7:19

0

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Browse other questions tagged or ask your own question.