export GO111MODULE=on export GOPROXY=https://goproxy.io
go mod init ~/go/src/kafka go get ./...
kafka-docker.md 记录了本地搭建kafka的方法
启动:
go run main.go -t mete
go run main.go -t produce
go run main.go -t consumer
go run main.go -t cluster
go run main.go -t cluster-part