如何设置春云流卡夫卡重新连接频率

Question

有没有办法在春季云流kafka绑定器中设置两次重新连接尝试之间的重新连接频率或时间？

如果kafka集群在应用程序运行时出现故障，它会不断尝试重新连接，CPU使用率会上升到100%。

我可以在KafkaConsumerProperties.java(spring-cloud-stream-binder-kafka-core-3.0.6.REASE的一部分(中看到一个属性recoveryInterval，但评论说它不推荐使用，绑定器没有使用它。有没有其他我可以使用的房产？

编辑：以下是我如何设置属性(根据此(：

# in application.properties
spring.cloud.stream.kafka.streams.binder.configuration.reconnect.backoff.ms=5000
spring.cloud.stream.kafka.streams.binder.configuration.reconnect.backoff.max.ms=10000

我也试着直接设置它，但也没用。

reconnect.backoff.ms=5000
reconnect.backoff.max.ms=10000

编辑2:

这样设置是有效的。但是CPU使用率仍然上升到100%。

# in application.properties
spring.cloud.stream.kafka.binder.configuration.reconnect.backoff.ms=5000
spring.cloud.stream.kafka.binder.configuration.reconnect.backoff.max.ms=10000

Answer 1

请参阅https://kafka.apache.org/documentation/#streamsconfigs_reconnect.backoff.ms

尝试重新连接到给定主机之前等待的基本时间。这样可以避免在紧密循环中重复连接到主机。此回退适用于客户端到代理的所有连接尝试。

和

https://kafka.apache.org/documentation/#streamsconfigs_reconnect.backoff.max.ms

重新连接到多次连接失败的代理时等待的最长时间(以毫秒为单位(。如果提供，每台主机的回退将在每次连续连接失败时呈指数级增加，最高可达此最大值。在计算退避增加后，添加20%的随机抖动以避免连接风暴。