Kafka参数zookeeper和bootstrap-server的区别

假定有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等

 

相关文章

Bootstrip HTML 查询搜索常用格式模版 &lt;form class=&...
如何在按钮上加红色数字 您可以使用Bootstrap的badge组件来在...
要让两个按钮左右排列,你可以使用 Bootstrap 的网格系统将它...
是的,可以将status设置为布尔类型,这样可以在前端使用复选...
前端工程师一般用的是Bootstrap的框架而不是样式,样式一般自...
起步导入:<linkrel="stylesheet"href="b...