因为笔记本是windows系统,做大数据相关,需要方便地搭建运行环境,所以本文记录下使用win10系统如何跑kafka。
版本:kafka 3.2.0。
1、去官网下载版本:

2、本人放置路径为:F:\kafka\kafka_2.12-3.2.0,这是解压后的。
3、需要修改\config下的一个配置server.properties,将数据文件路径修改为你需要的路径,本人如下:log.dirs=F:\kafka\logs

4、回到F:\kafka\kafka_2.12-3.2.0,开始启动zookeeper,运行:
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

5、运行
.\bin\windows\kafka-server-start.bat .\config\server.properties

6、创建主题,运行
.\bin\windows\kafka-topics.bat --create --topic flinksql --bootstrap-server localhost:9092
并且查看主题:
.\bin\windows\kafka-topics.bat --describe --topic flinksql --bootstrap-server localhost:9092

7、发送消息,运行
.\bin\windows\kafka-console-producer.bat --topic flinksql --bootstrap-server localhost:9092

8、消费消息,运行
.\bin\windows\kafka-console-consumer.bat --topic flinksql --from-beginning --bootstrap-server localhost:9092

至此,一个基本的kafka环境就算搭好。
网友评论