当前系统中produer配置request.timeout.ms=30000(30秒),但是broker端配置zookeeper.connection.timeout.ms=1000000,kafka集群中某台为leader的服务器宕机之后,broker在1000000ms之内不会触发rebalance,导致producer在30秒后出现超时
producer的回调方法中出现了
修改:调大(request.timeout.ms) 大于 (zookeeper.connection.timeout.ms)