千家信息网

Kafka中容易混淆的概念有哪些

发表于:2026-11-01 作者:千家信息网编辑
千家信息网最后更新 2026年11月01日,这篇文章主要介绍Kafka中容易混淆的概念有哪些,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!broker-listbroker指的是kafka的服务端,可以是一个服务器也可以
千家信息网最后更新 2026年11月01日Kafka中容易混淆的概念有哪些

这篇文章主要介绍Kafka中容易混淆的概念有哪些,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!


broker-list

broker指的是kafka的服务端,可以是一个服务器也可以是一个集群。producer和consumer都相当于这个服务端的客户端。

broker-list指定集群中的一个或者多个服务器,一般我们再使用console producer的时候,这个参数是必备参数,另外一个必备的参数是topic,如下示例:

C:\kafka\kafka_2.12-1.1.1
λ .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test20190713
>this is a test
>

本地主机如果要模拟多个broker,方法是复制多个server.properties,然后修改里面的端口, broker.id等配置模拟多个broker集群。

比如模拟三个broker的情况,首先把config 目录下的 server.properties 复制两份,分别命名为 server-1.properties 和 server-2.properties,然后修改这两个文件的下列属性,

server-1.properties:

broker.id=1
listeners=PLAINTEXT://:9093
log.dirs=C:/kafka/broker1

server-2.properties:

broker.id=2
listeners=PLAINTEXT://:9094
log.dirs=C:/kafka/broker2

broker.id 用来唯一标识每一个 broker,每个broker都有一个唯一的id值用来区分彼此。Kafka在启动时会在zookeeper中/brokers/ids路径下创建一个与当前broker的id为名称的虚节点,Kafka的健康状态检查就依赖于此节点。

我们可以打开一个zk的客户端,通过ls命令来查看下这个路径下的内容:

λ .\bin\windows\zookeeper-shell.bat localhost:2181
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled
ls
WATCHER::

WatchedEvent state:SyncConnected type:None path:null

ls /brokers/ids
[0]

可以看到我们默认启动的这个broker.id为0的节点。

bootstrap-servers vs zookeeper

bootstrap-servers指的是目标集群的服务器地址,这个和broker-list功能是一样的,只不过我们在console producer要求用后者。

以前我们使用console consumer测试消息收发时会这样写:

C:\kafka\kafka_2.12-1.1.1
λ .\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test20190713
Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major release. Consider using the new consumer by passing [bootstrap-server] instead of [zookeeper].

这样可以接收到生产者控制台发送的消息。

现在我们也可以这样写,

C:\kafka\kafka_2.12-1.1.1 λ .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test20190713

你可以自己测试下,也是可以收到消息的。

前者是老版本的用法,0.8以前的kafka,消费的进度(offset)是写在zk中的,所以consumer需要知道zk的地址。后来的版本都统一由broker管理,所以就用bootstrap-server了。

以上是"Kafka中容易混淆的概念有哪些"这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注行业资讯频道!

服务 多个 集群 内容 参数 服务器 消息 节点 概念 地址 客户 客户端 版本 篇文章 路径 测试 三个 两个 主机 价值 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 互联网科技海报 互联网科技公司排名 互联网下的科技发展 互联网的科技创新 南京欣网互联网科技 奔汉互联网科技 上海万想互联网科技 深圳艾佳互联网科技 互联网科技公司介绍 卓越科技互联网 招聘 镁科技互联网资讯平台 蓝色互联网科技 互联网和黑科技的看法 重庆互联网医院沙龙医盟信息科技 河南猎农互联网科技有限公司 米聚互联网科技南京有限公司排面 山东子淼互联网科技有限公司 张家口科技产业互联网平台 10位科技互联网大佬 科技发展第三阶段互联网时代 广东万易互联网科技有限公司惠州分公司 深圳齐家互联网科技 互联网高科技股票 人人互联网科技是培训 新华互联网科技校企合作 互联网科技公司需要的职位 中国互联网有什么科技含量 小米互联网科技园设置 为客找房互联网科技公司怎么样 安徽九吞吴互联网科技有限公司
0