Kafka如何设置生产者重试无限

kt06eoxx  于 2021-06-07  发布在  Kafka
关注(0)|答案(3)|浏览(736)

如何将spring boot属性spring.kafka.producer.retries设置为integer.max\u值?
取消设置此属性有效吗?还是默认为0?
@见基普默认Kafkahttps://cwiki.apache.org/confluence/display/kafka/kip-98+-+exactly+once+delivery+and+transactional+messaging

iibxawm4

iibxawm41#

根据Kafka文件,它默认为 Integer.MAX_VALUE (至少是目前的版本),这与kip是一致的。

2jcobegt

2jcobegt2#

默认情况下是 2147483647 哪个是 Integer.MAX_VALUE 你可以在 [0,...,2147483647] 检索Docs
设置一个大于零的值将导致客户机重新发送其发送失败的任何记录,并可能出现暂时性错误。请注意,此重试与客户端在收到错误时重新发送记录没有什么不同。允许重试而不设置 max.in.flight.requests.per.connection 到1可能会更改记录的顺序,因为如果将两个批发送到单个分区,第一个失败并重试,但第二个成功,那么第二个批中的记录可能会首先出现。另外请注意,如果配置了超时,则在重试次数用尽之前,生成请求将失败 delivery.timeout.ms 在成功确认之前先过期。用户通常应该不设置此配置,而是使用1delivery.timeout.ms1来控制重试行为。

xytpbqjk

xytpbqjk3#

的默认值 ProducerConfig.RETRIES_CONFIG2147483647 . 希望不定义retries属性会注意默认值

相关问题