Kafka客户端断开后反复自动重连如何禁用？是否需主动关闭客户端？

1、是否有配置方式可以禁用Kafka客户端的自动重连机制？ #

• 原生Kafka客户端（生产者、消费者、管理端通用）没有提供任何可直接关闭自动重连的配置项。自动重连是客户端网络层内置的默认逻辑，只要客户端实例未被销毁，连接断开后就会按照退避策略循环尝试重连，你看到的反复打印断开日志就是这个逻辑触发的。
• 现有配置只能调整重连的间隔节奏，无法彻底关闭重连行为：
  • reconnect.backoff.ms：两次重连的基础等待时长，默认50ms
  • reconnect.backoff.max.ms：重连等待的最大时长，默认1000ms，连续重连失败时等待时间会指数递增直到触达该上限
• 如果业务场景必须禁止自动重连，只能通过二次修改客户端源码，或者在外层逻辑监听到连接失败事件后主动销毁客户端实例实现，没有原生配置支持。

2、出现连接异常时是否需要主动关闭Kafka客户端？ #

根据故障类型判断即可，不需要一报错就关客户端：

• 如果是临时网络抖动、Broker滚动重启这类可自愈的故障，完全不需要主动关闭客户端。自动重连本身就是为这类场景设计的容错机制，故障恢复后客户端会自动重建连接、恢复生产消费逻辑，主动关闭反而会中断正常业务。
• 如果是确认无法恢复的故障，比如Bootstrap地址配置错误、集群已永久下线、当前业务流程已经不需要和Kafka交互，必须主动调用客户端的close()方法销毁实例。否则客户端会一直持有后台工作线程、网络端口等资源，无限循环执行重连逻辑打印冗余日志，造成资源泄漏。
• 你贴出的日志提示引导节点断开、Broker不可达，优先排查Broker地址配置是否正确、集群是否正常运行、网络防火墙/安全组是否放通对应端口。如果是配置错误这类无法自动恢复的问题，修正配置前建议先关闭初始化失败的客户端实例，避免无意义的资源消耗。

问题对应运行日志：

[2022-06-30 16:17:51,332] WARN [Consumer clientId=consumer-xxx, groupId=xxx] Bootstrap broker xxx:xxx (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2022-06-30 16:17:52,387] WARN [Consumer clientId=consumer-pg-hudi001_5-1, groupId=pg-hudi001_5] Connection to node -1 (xxx) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

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