Raj
Raj

Reputation: 1727

what happens to the messages in producer 'buffer.memory' if the producer app is crashed before they were sent to the broker?

I am using spring-kafka 2.2.8 and writing a simple producer with the below settings: linger.ms : 5 max.block.ms: 60000

Now my question is, what happens to the messages in producer 'buffer.memory' if the producer app is crashed before they were sent to the broker (especially in a asynchronous producer call mode)?

Is there any option to capture the status of these messages?

Upvotes: 0

Views: 354

Answers (1)

Gary Russell
Gary Russell

Reputation: 174709

The records will be lost; you need to get the result of the Future for the send to ensure that they actually arrived at the broker.

Upvotes: 1

Related Questions