当前系统中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)
微信扫描二维码，关注我的公众号