如何设置使用者的最大重试次数

sqserrrh 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(365)

我想知道，如果它存在一个消费者的属性，当Kafka服务器不可用设置多少次，它应该尝试连接到Kafka服务器。
我也试过：

.withProperty(ConsumerConfig.RECONNECT_BACKOFF_MAX_MS_CONFIG, "4000")
.withProperty(ConsumerConfig.RETRY_BACKOFF_MS_CONFIG, "500")
.withProperty(ConsumerConfig.RECONNECT_BACKOFF_MS_CONFIG, "500")

看来，这是行不通的。根据以上设置，我预计消费者在4s重新连接后会停止。
据我所知，对于producer，它存在retries属性。

apache-kafka kafka-consumer-api

来源：https://stackoverflow.com/questions/55786702/how-to-set-maximal-retry-of-consumer

1条答案

按热度按时间

64jmpszr1#

没有限制使用者端重试次数的配置。
但是，有一些参数可以控制重联频率

reconnect.backoff.max.ms

reconnect.backoff.ms

retry.backoff.ms

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

我来回答

如何设置使用者的最大重试次数

1条答案

相关问题

热门标签

最新问答