重试逻辑在 kafka 生产者中如何工作？

【问题标题】：How does the retry logic works in kafka producers?重试逻辑在 kafka 生产者中如何工作？
【发布时间】：2021-08-26 02:45:11
【问题描述】：

重试逻辑在生产者中是如何工作的？

查看了与重试相关的生产者配置文档，但看不懂？

请简化并帮助我理解。谢谢

【问题讨论】：

如果您的记录发送失败，将再次分批发送。究竟是什么难以理解？

标签： apache-kafka producer

【解决方案1】：

Producer 配置属性 retries 默认为 0，是重试次数如果 Producer 没有从 Kafka Broker 得到确认，则计数。制片人仅当记录发送失败被视为暂时错误 (API) 时才会重试。生产者的行为就像您的生产者代码重新发送记录一样尝试失败。请注意，超时会重新尝试，但 retry.backoff.ms （默认为 100 毫秒）用于在失败后等待重试再次请求。如果你设置重试> 0，那么你也应该设置 max.in.flight.requests.per.connection 为 1，或者有重试消息可能会乱序传递。您必须决定乱序消息传递是否对您的申请。

更多详情请参考here

【讨论】：