Hi Community, I use Kafka Java Client to send messages asynchronously.
I wonder if the producer fails to send a message, during the retry
period, will the callback be executed for each retry?
I debugged the source code
org.apache.kafka.clients.producer.internals.Sender#canRetry and
org.apache.kafka.clients.producer.internals.Sender#reenqueueBatch
parts, and I'm still not sure.
Can anyone help answer this question?
In addition, is there any way to make Kafka producers retry locally? I
want to completely understand the code logic.
Thanks!
