kafka重试次数配置
时间: 2023-10-06 20:06:20 浏览: 86
在Kafka中,有一个参数叫做retries,用于设置客户端在发送消息失败时进行重试的次数。 默认情况下,retries参数的值被设置为0,即快速失败模式,表示当发送失败时,客户端不会进行重试,而是由客户端决定是否继续发送后续的消息。
如果你想要开启重试功能,可以将retries参数设置为大于0的值。在0.11.3版本及以上的Kafka中,当retries大于0时,客户端会在发送消息失败时,进行重试并重新发送消息。需要注意的是,如果没有将max.in.flight.requests.per.connection参数设置为1,那么重试可能会导致消息的顺序发生变化。例如,如果两个批次的消息发送到同一个分区,第一个批次发送失败并进行了重试,而第二个批次发送成功,那么第二个批次的消息可能会先出现在消费者端。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [Kafka Producer重试参数retries设置取舍【实战笔记】](https://blog.csdn.net/gaoliang1719/article/details/106030826)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]