问题出现的场景： 有个go写的项目，原来是用go vendor来管理依赖包的，现在改为是用go module方式了，转换之后，编译成功，发现了上面的错误。很显然连接kafka集群报错了。 问题的原因： 网上搜了下，很多说是防火墙啥的问题，其实不是。本质原因是，我项目使用的如下kafka客户端库 github.com/Shopify/sarama 版本升级到当前最新版，这个最新版无法连接k

发现是ZK问题，重启ZK后，再同步kafka中数据，logstash日志就正常了。 ZK配置如下： docker run --name myzk -p 2181:2181 -d jplock/zookeeper   Kafka配置如下: docker run -d --name mykafka --publish 9092:9092 --link myzk --env KAFKA_ZOO