作为Kafka的新手,试图了解Kafka中的重试概念。什么基础的重试过程将完成?示例Retries参数我们设置为7。现在在这里提问,
在分布式系统中,不可避免重试。从网络错误到复制问题,甚至下游依存关系中断,必须准备大规模运行的服务,以尽可能优雅地遇到,识别和处理故障。
Kafka将重试,直到成功完成启动的过程或重试计数为零。
[Kafka保持每个呼叫的状态,并根据此重试次数减少。
请在以下URL中通过Sender.java的completeBatch函数来获取更多信息。
https://github.com/apache/kafka/blob/68ac551966e2be5b13adb2f703a01211e6f7a34b/clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java