Windows上启动Kafka，创建测试实例，关闭kafka

保姆级运行kafka教程

下载Kafka压缩包

Apache官网下载链接
如下图：

选择自己喜欢的版本，这里进行演示的版本是kafka_2.12-2.3.0

然后直接解压到随便一个文件夹即可（后面要用到文件夹路径）

1、配置两个文件server.properties和zookeeper.properties

然编辑config目录下的server.properties，更改自己存放日志的目录即可，如图

然后是编辑同目录下的zookeeper.properties，改自己的目录，如图

接下来就可以开始启动了
因为Kafka依赖Zookeeper，所以先启动zookeeper

3、启动zookeeper：

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

不要当前窗口，重新打开新的窗口进入文件目录

4、启动kafka：

bin\windows\kafka-server-start.bat config\server.properties

5、创建测试主题

依旧不要关闭当前窗口，开启新窗口进行创建主题test测试
创建 Topic（该命令 表示创建一个 名为 test 的主题，1 个副本，1个分区）

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1  --topic test

查看当前服务器的刚才创建的主题

kafka-topics.bat --list --bootstrap-server localhost:9092

6、创建生产者

往指定主题上发消息进行测试（这里发的是一个hello和一个world）

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

打开新的命令行窗口

7、启动消费者

（beginning表示从最开始读取生产者的消息）

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

读取到了刚才生产者发布的消息

注意！关闭时不能直接关闭窗口，否则很可能会导致kafka无法完成对日志文件的解锁。届时，再次启动kafka的时候，就会提示日志文件被锁，无法成功启动

！！！千万不要手动暴力关闭，用下面的命令关闭（如果暴力关闭了，解决方案：方案：将kafka的日志文件全部删除，再次启动即可。）
关闭zookeeper服务器

zookeeper-server-stop.bat    

关闭kafka服务器

kafka-server-stop.bat