使用Kafka工具,我的配置如下:
Zookeeper Host:192.168.60.97
Zookeeper Port:2181
chroot path: /kafka1
但是当我尝试这个
consumer, err = sarama.NewConsumer([]string{"192.168.60.97:2181:/kafka1"}, nil)
我总是
kafka: client has run out of available brokers to talk to (Is your cluster reachable?)
我该怎么办?