版本: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环境就算搭好。
网友评论