> will the callback be executed for each retry The callback will be triggered only once when the produce is finally ended up with succeeded or failed after retries.
> is there any way to make Kafka producers retry locally Easiest way would be to make produce failing artificially. it can be done by e.g.: - set acks=all and set topic's min.insync.replicas to impossibly large value - use iptables between producer and broker to block the network connectivity 2023年11月12日(日) 18:10 王有胜 <wonderfulserendipi...@gmail.com>: > 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! > -- ======================== Okada Haruki ocadar...@gmail.com ========================
