Windows下安装运行kafka
1. 下载并启动zookeeper,详见https://www.cnblogs.com/azhuya/p/15124799.html (注意不要关闭启动窗口)
2 . 下载kafka:http://kafka.apache.org/downloads.html (注意下载binary版本的)
3. 解压到相应文件夹,进入config目录下,找到server.properties文件,并作以下修改:
找到并编辑 log.dirs=D:\soft\kafka\kafka_2.13-2.8.0\kafka-logs (kafka的解压目录,kafka-logs文件夹不用自己新建)
找到并编辑zookeeper.connect=localhost:2181 (一般默认就是localhost:2181)
4. 启动kafka,win+R 输入cmd,打开命令窗口,进入安装目录 D:\soft\kafka\kafka_2.13-2.8.0,输入以下命令 ( 成功之后不要关闭窗口)
.\bin\windows\kafka-server-start.bat .\config\server.properties
5. 测试
1)创建主题,打开一个新的命令窗口,进入安装目录 D:\soft\kafka\kafka_2.13-2.8.0,输入以下命令 ( 成功之后不要关闭窗口)
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
输入查看主题命令:
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
2)创建生产者,打开一个新的命令窗口,进入安装目录 D:\soft\kafka\kafka_2.13-2.8.0,输入以下命令 ( 成功之后不要关闭窗口)
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
输入内容:hello world!
3)创建消费者,打开一个新的命令窗口,进入安装目录 D:\soft\kafka\kafka_2.13-2.8.0,输入以下命令 ( 成功之后不要关闭窗口)
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
这里接收生产者的消息。
参考地址:https://www.cnblogs.com/flower1990/p/7466882.html