Reputation: 1727
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
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