Windows下运行kafka_kafka windows

官网下载kafka压缩包

运行前要先配置JAVA环境：java下载地址

请点击：官网地址

注意啦！！！kafka不需要搭建zookeeper环境哦~kafka自带了这个环境呦！！！

2、解压并进入Kafka目录

3、点击进入该目录 右键打开黑窗口

1.zookeeper 启动命令（不要关闭黑窗口哦）
.\bin\windows\zookeeper-server-start.bat config\zookeeper.properties
1
2

运行结果：

注意：不要关了这个窗口

运行kafka

重新打开一个黑窗口运行kafka

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

运行结果（kafka开启成功）

注意：不要关了这个窗口

标题下面我们来进行测试

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

1
2

注意：不要关了这个窗口

它会创建test主题

查看我们看看创建好的主题

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

1
2

注意：不要关了这个窗口

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

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

1
2

注意：不要关了这个窗口

创建消费者，进入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

1
2

完事啦~~~~

要在生产者的黑窗口输入消息（消费者接收消息，中文有乱码哈~~~）