假定有3台机，主机名是node1、node2、node3，以创建一个topic为例：
旧版（< v2.2）
kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --create --topic ..
新版（>= v2.2）
kafka-topics.sh --bootstrap-server node1:9092 --create --topic ..
其中，2181是ZooKeeper的监听端口，9092是Kafka的监听端口。
旧版用--zookeeper参数，主机名（或IP）和端口用ZooKeeper的，也就是server.properties文件中zookeeper.connect属性的配置值
新旧用--bootstrap-server参数，主机名（或IP）和端口用某个节点的即可，即主机名（或主机IP）:9092。
如果没有使用对应版本的命令，会报以下错误：
Error while executing topic command : Timed out waiting for a node assignment. Call: xxx ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: xxx
该错误是由于没有用对应版本的命令，访问了错的主机名（或IP）和端口，所以请求失败导致超时。
* 其中的xxx是指具体的动作，例如createtopics、listTopics等。
另外，如果没配置server.properties文件的listeners值，也会报以上错误。
listeners值默认是PLAINTEXT://:9092，要改为PLAINTEXT://localhost:9092或PLAINTEXT://node1:9092等
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
