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

kt06eoxx 于 2021-06-07 发布在 Kafka

关注(0)|答案(3)|浏览(749)

如何将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

apache-kafka spring-boot spring-kafka

来源：https://stackoverflow.com/questions/53708540/kafka-how-to-set-producer-retries-to-infinity

3条答案

按热度按时间

iibxawm41#

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

赞(0）回复(0）举报 2021-06-07

2jcobegt2#

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

赞(0）回复(0）举报 2021-06-07

xytpbqjk3#

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

赞(0）回复(0）举报 2021-06-07