前言:
当前姐妹们对“kafka环境搭建及demo”都比较关切,你们都需要了解一些“kafka环境搭建及demo”的相关文章。那么小编也在网络上网罗了一些对于“kafka环境搭建及demo””的相关资讯,希望大家能喜欢,朋友们一起来了解一下吧!1、JDK环境搭建
前面已将
2、zookeeper环境搭建
前面已将
3、kafka环境搭建
1)下载地址
2)解压,配置
解压文件(我的目录是D:\kafka_2.12-0.11.0.0 【这里不要在Program Files等文件名之间有空格的目录下,不然一会执行会不识别路径】)
打开目录D:\kafka_2.12-0.11.0.0\config下server.properties文件,把log.dirs修改为【log.dirs=D:\kafka_2.12-0.11.0.0\kafka-logs】
3)启动:broker
进入kafka文件目录D:\kafka_2.12-0.11.0.0,执行以下命令,启动kafka通讯的服务器broker
.\bin\windows\kafka-server-start.bat .\config\server.properties
4)创建topic
进入kafka文件目录D:\kafka_2.12-0.11.0.0\bin\windows,创建kafka的消息topics
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo
分别打开两个cmd窗口,进入目录D:\kafka_2.12-0.11.0.0\bin\windows,创建Producer和Consumer
5)启动provider
进入目录D:\kafka_2.12-0.11.0.0\bin\windows输入如下命令
kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo
6)启动consumer
进入目录D:\kafka_2.12-0.11.0.0\bin\windows输入如下命令
kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo
然后就可以在Producer中发信息,在Consumer中收信息了
标签: #kafka环境搭建及demo