In your producer have you set acks to be βallβ and retries to be something
higher than β0β?
props.put("acks", "all");
props.put("retries", 2147483647);
Also if the order of the messages matter you should also set the max inflight
messages to 1 so retries happen and succeed before any other mes
Hi ,
I am using kafka 10.2 and sometime my producer does not sends me any ACK
and in that case data is also not pushed.
Whenever I get ACK I am able to consume data.
But this is happening quiet often with me and i have no clue why data is
not being pushed inside and my request ends gracefully a