一、Kafka下载和安装

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

下载完毕解压即可
linux解压命令tar -zxvf kafka_2.13-3.5.1.tgz，linux环境下指令是在\kafka_2.13-3.5.1\bin目录。
windows直接解压即可，windows环境下指令是在kafka_2.13-3.5.1\bin\windows目录。
注意：不同系统指令所在的目录不同。
执行命令当前目录D:\env-java\kafka_2.13-3.5.1

修改 kafka-server 和zookeeper配置

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

• linux系统:

broker.id=1
log.dir=/Users/imagetask/kafka-logs

• windows系统:

broker.id=1
log.dirs=/env-java/kafka_2.13-3.5.1/kafka-logs

/：表示当前的根路径，即D盘。没有就会创建对应的文件夹。

二、Kafka使用

1、启动ZooKeeper

• linux系统:

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

• windows系统:

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

2、启动kafka

• linux系统:

bin/kafka-server-start.sh config/server.properties

• windows系统:

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

3、创建主题

• linux系统:

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

• windows系统:

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

4、查看Topic 列表

• linux系统:

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

• windows系统:

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

5、启动 Producer

• linux系统:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

• windows系统:

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

6、启动 Consumer

• linux系统:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

• windows系统:

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

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

• linux系统:

bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test

• windows系统:

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