Kafka参数zookeeper和bootstrap-server的区别
2021/11/7 23:13:56
本文主要是介绍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等
这篇关于Kafka参数zookeeper和bootstrap-server的区别的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08「布道师系列文章」解析 AutoMQ 对象存储中的文件存储格式
- 2024-05-08「布道师系列文章」小红书黄章衡:AutoMQ Serverless 基石-秒级分区迁移
- 2024-05-08AutoMQ 系统测试体系揭秘
- 2024-03-14AutoMQ 携手阿里云共同发布新一代云原生 Kafka,帮助得物有效压缩 85% Kafka 云支出!
- 2024-02-22kafka partitioner
- 2024-01-24AutoMQ生态集成 - 将数据从 AutoMQ Kafka 导入 RisingWave 数据库
- 2024-01-13消息队列面试题:为什么要使用消息队列?
- 2024-01-08"基于 XHAMQ 的消息队列系统实现"
- 2023-11-24全网最全图解Kafka适用场景
- 2023-09-19RabbitMQ 消息应答