参考以下文章：
https://blog.csdn.net/tflasd1157/article/details/81985722
补充上述的一些坑
配置完zk和kafka之后，不用特定进入到kafka的目录，命令前不用加./bin/
创建topic时的命令：
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tes
下载两个依赖
go get github.com/Shopify/sarama@v1.24.1
go get github.com/bsm/sarama-cluster
sarama版本选择v1.24.1,因为最新版本的sarama依赖的消费者会报错。
go get 如果出错的话，配一下环境变量
export GO111MODULE=on export GOPRIVATE='*.corp.example.com' GOPROXY=https://goproxy.io,direct
goland的Go Modules也配置一下
具体位置在左上角GoLand->Preferences 就可以找到
上述配完，拉依赖就应该没问题了。
在go的代码中，记得把地址的域名换成本地的，我换成了localhost就好使了
