已安装Zookeeper 并启动

1、下载安装包 

https://link.zhihu.com/?target=https%3A//archive.apache.org/dist/kafka/2.4.1/kafka_2.12-2.4.1.tgz

2.解压后将config目录下server.properties文件的log.dirs值修改为如：自己解压的地址的data目录下，如图所示：

启动监听如图

3.打开cmd窗口，进入解压的bin目录里的windos的bat脚本所在的目录并执行如下命令

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

如果没看到报错，基本就算启动成功了

4、创建一个topic为test   打开一个新的cmd窗口

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

———————————————————————————————————————————

查看 test主题的详情 kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test

Topic:test：主体的名称是test。

Partition：分区编号是0，代表只有一个分区，编号从0开始

Leader：每个分区多个副本的主节点编号，这个在集群中才会是其它值，这里是单机模式，值等于唯一副本编号

Replicas：副本编号，也是从0开始。

修改分区数 注意：分区数只能增加，不能减少

kafka-topics.bat --bootstrap-server localhost:9092 --alter --topic test --partitions 2

删除 topic

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

———————————————————————————————————————————

5、在刚才创建topic的窗口里创建一个消息的生产者

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

———————————————————————————————————————————
新打开一个cmd窗口，来创建一个消费者来接收生产者生产的消息 

1）消费 test主题中的数据。 只能消费消费者出现之后的数据

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

2）把主题中所有的数据都读取出来（包括历史数据）

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

———————————————————————————————————————————
6、然后我们用刚才的生产者来发送消息，看看消费者能不能收到：

————————————————