Windows下安装运行Kafka(单节点)

安装kafka需要提前安装Zookeeper

一、Zookeeper安装

1.  下载安装包 https://zookeeper.apache.org/releases.html 注意：要下载带bin的安装包

2.  解压并进入ZooKeeper目录，如：D:\onworking\apache-zookeeper-3.7.0-bin，新建data目录

3.  进入conf目录，复制一份zoo_sample.cfg重命名为zoo.cfg

4.  编辑zoo.cfg，dataDir=D:\\onworking\\apache-zookeeper-3.7.0-bin\\data

5.  进入bin目录，双击zkServer.cmd运行Zookeeper

6.  出现如下截图则Zookeeper启动成功

二、 Kafka安装

1.  下载安装包 https://kafka.apache.org/downloads

2.  解压并进入Kafka目录，如：D:\onworking\kafka_2.13-3.1.0，新建kafka-logs目录

3.  进入config目录，编辑server.properties文件log.dirs=D:\\onworking\\kafka_2.13-3.1.0\\kafka-logs

4.  在D:\onworking\kafka_2.13-3.1.0目录下打开cmd窗口，输入命令.\bin\windows\kafka-server-start.bat .\config\server.properties

5.  出现如下截图则Kafka启动成功 

三、Windows下 Kafka常用命令 -topic的增删改查

进入kafka目录下，不用进入bin目录下

-- 查看所有topic

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

-- 查看指定topic信息

.\bin\windows\kafka-topics.bat --zookeeper localhost:2181 --describe --topic <主题名称>

-- 创建topic信息

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic <主题名称>

-- 创建生产者产生消息，不关闭页面

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic <主题名称>

-- 创建消费者接收消息，不关闭页面

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic <主题名称> --from-beginning

-- 删除topic：

.\bin\windows\kafka-topics.bat kafka.admin.DeleteTopicCommand --zookeeper localhost:2181 --delete --topic <主题名称>

四、Windows下查看消费情况

--查询所有消费者组

.\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list

--查询对应组的消费情况

.\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group <上一步查询出来的组的名称> --describe

参数说明

---------------------------------------------------------------

ps:当启动Zookeeper或Kafka报文件夹错误时

1.清理zookeeper的dataDir目录里面的内容，zoo.cfg里面的指定的dataDir目录（数据请提前备份)

2.清理kafka文件夹下kafka_logs和logs目录里面的内容（数据请提前备份)