下载安装Kafka参考：

https://blog.csdn.net/tttzzzqqq2018/article/details/132127105

1.1Kafka启动

由于Kafka依赖于Zookeeper，所以要先启动Zookeeper，再启动Kafka

1.1.1、先启动Zookeeper服务

管理员权限打开命令窗口，输入命令zkServer，启动Zookeeper服务：zkServer

1.1.2、再启动Kafka服务

管理员权限打开命令窗口，进入到Kafka安装目录（D:\soft\kafka\kafka_2.12-2.8.2）。
输入如下命令启动Kafka服务：

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

2.4、Kafka相关操作（Kafka新版本命令）

Kafka2.2之后版本中使用–zookeeper hadoop01:2181会出现报错情况，2.2之后的版本使用了–bootstrap-server hadoop01:9092来替换–zookeeper hadoop01:2181

创建topics

以管理员权限新开一个命令提示窗口，进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录，执行以下命令，创建topics：

kafka-topics.bat --create --bootstrap-server xx.xx.x.xxx:xxxx --replication-factor 1 --partitions 1 --topic test

查看topics  查看topics列表：

.\kafka-topics.bat --bootstrap-server xx.xx.x.xxx:xxxx --list

打开一个producer（生产者）

以管理员权限新开一个命令提示窗口，进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录，

执行以下命令，打开一个producer（生产者）：

.\kafka-console-producer.bat --broker-list xx.xx.x.xxx:xxxx --topic test

打开一个consumer（消费者）

以管理员权限新开一个命令提示窗口，进入D:\bigdata\kafka\2.12-3.5.1\bin\windows目录，执行以下命令，打开一个consumer（消费者）：

.\kafka-console-consumer.bat --bootstrap-server xx.xx.x.xxx:xxxx --topic test1 --from-beginning