Kafka的broker-list,bootstrap-server以及zookeeper的关系
broker指的是kafka的服务端,可以是一个服务器也可以是一个集群。producer和consumer都相当于这个服务端的客户端。
broker-list用来指定集群中的一个或者多个服务器,一般我们再使用console producer的时候,这个参数是必备参数;另外一个必备的参数是topic,如下示例:
[atguigu@hadoop102 kafka]$ bin/kafka-console-producer.sh --broker-list hadoop002:9092 --topic first
bootstrap-servers指的是目标集群的服务器地址,这个和broker-list功能是一样的,只不过我们在使用console consumer时要求用前者。
## 之前的写法
## 老版本的用法,0.8以前的kafka,消费的进度(offset)是写在zk中的,所以consumer需要知道zk的地址。
## 这个方案有性能问题,0.9 的时候整体大改了一次,brokers 接管了消费进度,consumer 不再需要和 zookeeper 通信了,所以就用bootstrap-server了。C:\kafka\kafka_2.12-1.1.1 λ .\bin\windows\kafka-console-consumer.sh --zookeeper localhost:2181 --topic test ## 新版本写法
## 新版的 Kafka 使用一个选举出来的 controller 来监听 zookeeper,其他 node 再去和 controller 通信,这么做的目的是为了减少 zookeeper 的压力。[atguigu@hadoop103 kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic topic_start
Kafka的broker-list,bootstrap-server以及zookeeper的关系相关推荐
- Kafka与zk的关系及连接参数bootstrap.server的正确理解
1.我们知道旧版Kafka,用的是zookeeper地址而非bootstrap.servers, 那么新版 kafka 消费者.生产者配置为何使用 bootstrap-servers 而不是 zook ...
- Kafka bootstrap.server is not a recognized option
1. 现象 kafka-console-consumer.sh --bootstrap.server=localhost:9092 --topic=file-connector-example-top ...
- Kafka系统的组件、角色以及和zookeeper的关系
broker: 每个正在运行的kafka节点,部署kafka的服务器, 以broker.id来区分 producer:消息生产者 consumer:消息的消费者 consumer group:消费者组 ...
- kafka的broker配置
1.broker.id 每个broker都需要一个broker.id来唯一标识,它的默认值是0,也可以被设置成其他任意的整数.这个值在整个kafka集群里必须是唯一的,这个值是任意的整数,但是建议设置 ...
- couldn't register *** with the bootstrap server. Error: unknown error code.
Couldn't register com.gdou.zhy.zhysimpleTable with the bootstrap server. Error: unknown error code. ...
- Apache Kafka 不需要管理员:删除 Apache ZooKeeper 的依赖
点击上方"朱小厮的博客",选择"设为星标" 后台回复"加群",加入新技术 目前,Apache Kafka 使用 Apache ZooKeep ...
- Couldn't register com.zyg.ios.XXX with the bootstrap server. Error: unknown error code.
运行应用突然崩溃,然后再次运行就出现了如下错误: Couldn't register com.zyg.ios.XXX with the bootstrap server. Error: unknown ...
- Access和SQL server开启表间关系,并实现更新或删除母表数据自动更新或删除子表数据...
1.Access开启表间关系,并实现删除母表数据自动删除子表数据: 在Tables等界面 - > 右键 - > Relationships... -> 弹出Relationships ...
- zabbix监控系统下——zabbix实现数据库监控、对JMX的支持、server和agent的关系、zabbix监控报警平台
目录 五.zabbix实现数据库监控 1.在agent端设置 2.在浏览器前端设置 六.zabbix对JMX(Java)应用的支持 七.server和agent的关系 1.agent端的信息采集变被动 ...
- kafka报错:Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
这是一个惨痛的教训 就在昨天我和我四个同事因为这个问题搞到了夜里十一点半,啊啊啊啊啊!!!太恶心了!!! 在启动工程时,kafka报这个错误,在配置文件中配置kafka的依赖,和另一个服务器上配置的一 ...
最新文章
- ROS修改pkg与node名字
- Nature替宠物正名了:宝宝身体好,猫狗或真不可少!
- Messaging CorrelationID
- 复旦计算机学硕分数线,复旦大学2019考研分数线公布,复旦复试经验请收好!...
- NFV节省企业宽带成本—Vecloud微云
- os.path python使用遍历文件夹文件
- ftp服务器搭建遇到的问题
- 前端学习(2708):重读vue电商网站28之通过axios请求拦截器添加 token
- 广播BroadcastReceiver(2)
- 2020-07-05
- Java中将List转成逗号数组的方案
- 定义一个内核panic问题
- MFC对TXT文档的操作—读、写、删、查
- RHEL7 CentOS7 检查查看精简指令
- 计算机网络故障提出问题,列控系统及其计算机网络的故障诊断与故障容错研究...
- 机器学习基础教程——最小二乘法案列
- 米兔机器人魔方_米兔指尖积木?就要盘它
- 浏览器(2):自制Chromium内核浏览器,自动统计CSDN社区打卡记录
- Auto.js实现自动删除朋友圈照片
- JAVA IO必会概念