kafka安装

最新推荐文章于 2025-03-31 15:45:23 发布

淡忘瞬间dream

最新推荐文章于 2025-03-31 15:45:23 发布

阅读量194

点赞数

分类专栏：大数据 spark

本文链接：https://blog.csdn.net/Bridge3/article/details/103618677

版权

大数据同时被 2 个专栏收录

6 篇文章

订阅专栏

spark

5 篇文章

订阅专栏

win10

单机配置

1. 配置安装

Java
Zookeeper

2. 运行zookeeper 服务的zkServer.cmd,不要关闭窗口

在这里插入图片描述

3. 编辑文件“server.properties”（在kafaka安装目录下\config 目录下）

• 找到并编辑log.dirs=D:\Java\Tool\kafka_2.11-0.10.0.1\kafka-log,这里的目录自己修改成自己喜欢的
• 找到并编辑zookeeper.connect=localhost:2181。表示本地运行
• Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181

4. 启动kafka 服务器（先进入kafka 安装目录）

执行：

.\bin\windows\kafka-server-start.bat .\config\server.properties

在这里插入图片描述
不要关闭窗口

5. 创建主题

执行：

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic linlin

在这里插入图片描述

6. 创建生产者

执行：

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic linlin

在这里插入图片描述 fig 4

（此时等待输入数据）

7. 创建消费者

执行：

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic linlin

在这里插入图片描述 fig 5

（注意：提示”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]“ 不用管，不建议将ConsoleConsumer与旧用户一起使用，并且在以后的主要版本中将删除该控制台。考虑通过传递[bootstrap-server]而不是[zookeeper]使用新使用者）