search

payara / ecosystem-support

Placeholder repository to handle community requests for the Payara Platform ecosystem tools
3 stars 2 forks source link

[Kafka Clarification] Messages commitment manual control #20

Closed imbananko closed 3 years ago

imbananko commented 4 years ago

Hello, I'm using manually built KafkaRAR And my question: Is there a way to control offset commitment of incoming messages? For example I have:

@OnRecord(topics = {"test-topic"})
    public void getMessage(ConsumerRecords record) {
        //business
    }

If some exception happens, how can I tell producer to keep the current offset? Or to resend same message (with the same offset)?

AlanRoth commented 3 years ago

Hi @imbananko,

Questions like this are best posted in our Payara Forum.

Thank you for your understanding, Alan