一、Kafka下载

下载地址：https://kafka.apache.org/downloads

二、Kafka安装

因为选择下载的是 .zip 文件，直接跳过安装，一步到位。
选择在任一磁盘创建空文件夹（不要使用中文路径），解压之后把文件夹内容剪切进去（本人选择 D:\env-java\路径下，即完成安装）。

• windows直接解压即可，windows环境下指令是在kafka_2.13-2.8.0\bin\windows目录。
  注意：不同系统指令所在的目录不同。
  执行命令当前目录D:\kafka\kafka_2.13-2.8

修改 kafka-server 和zookeeper配置

进入到目录：kafka_2.13-2.8.0/config/server.properties
以及kafka_2.13-2.8.0/config/zookeeper.properties

• Windows系统

server.properties文件中修改
broker.id=1
log.dirs=/kafka/kafka_2.13-2.8.0/kafka-logs

zookeeper.properties文件中修改
dataDir=/kafka/kafka_2.13-2.8.0/zookeeper-logs

三、启动Kafka服务

1、启动ZooKeeper

• Windows系统

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

2、启动kafka

• Windows系统

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

四、Kafka的使用

1、创建主题

• Windows系统

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

bin/kafka-server-stop.sh -daemon config/server.properties

• 创建kafka主题-kafka提供了一个名为kafka-topic.sh的命令实用程序，用于在服务器上创建主题

2、删除主题

• Windows系统

bin\windows\kafka-topics.bat --delete --bootstrap-server localhost:9092 --topic test

3、查看Topic 列表

• Window系统

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

4、启动 Producer

• Window系统

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

5、启动 Consumer

• Window系统

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

6、查看Topic 相关信息（test）

• Window系统

bin\windows\kafka-topics.bat --describe --bootstrap-server localhost:9092 --topic test