kafka的安装运行

Posted 2022-11-15 FreeFly辉

原文链接：
https://blog.csdn.net/weixin_38004638/article/details/91893910

三、安装Kafka
1、 下载安装包

http://kafka.apache.org/downloads

注意要下载二进制版本

2、 解压并进入Kafka目录，笔者：D:\\Kafka\\kafka_2.12-0.11.0.0

3、 进入config目录找到文件server.properties并打开

5、 找到并编辑zookeeper.connect=localhost:2181

6、 Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181

7、 进入Kafka安装目录D:\\Kafka\\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

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

注意：注意：不要关了这个窗口，启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

四、测试
（linux直接在bin目录下.sh，windows需要进入bin\\winndows下的.bat）

1、 创建主题，进入Kafka安装目录D:\\Kafka\\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

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

注意：不要关了这个窗口

2、查看主题输入：

.\\bin\\windows\\kafka-topics.bat --list --zookeeper localhost:2181

3、 创建生产者，进入Kafka安装目录D:\\Kafka\\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

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

4、 创建消费者，进入Kafka安装目录D:\\Kafka\\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

.\\bin\\windows\\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

5、查看topic，进入Kafka安装目录D:\\Kafka\\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：