如何修改Kafka客户端连接失败后的6分钟重试时长？

Kafka客户端（生产者/消费者）默认会持续尝试重新连接集群，你观察到的6分钟重试时长是默认配置下的累积表现。可以通过以下核心配置调整重试的间隔和总时长：

• reconnect.backoff.ms：初始重试连接间隔，默认50ms。每次重试后间隔时间会指数级递增，直到达到最大值。
• reconnect.backoff.max.ms：重试连接的最大间隔，默认1000ms（1秒）。调高这个值会增加每次重试的等待时间，从而拉长总重试时长；调低则会让重试更频繁，但总时长可能缩短。
• 生产者专属配置：delivery.timeout.ms，默认300000ms（5分钟）。该配置定义了消息从发送到被确认的总超时时间，若超过此时间仍无法连接成功，生产者会抛出超时异常并停止重试。
• 消费者专属配置：session.timeout.ms（默认45000ms）和max.poll.interval.ms（默认300000ms）。会话超时后消费者会退出消费组，结合reconnect.backoff系列配置可间接控制连接重试的周期。

示例配置（以缩短总重试时长至1分钟左右为例）：

# 初始重试间隔
reconnect.backoff.ms=100
# 最大重试间隔
reconnect.backoff.max.ms=500
# 生产者总发送超时
delivery.timeout.ms=60000
# 消费者会话超时
session.timeout.ms=10000

注意：不同Kafka客户端版本的配置可能存在细微差异，请结合你使用的版本确认具体参数。

内容的提问来源于stack exchange，提问作者Michele Pedrotti