进入Kafka官网:Apache Kafka下载最新版Kafka
2.将Kafka路径配置到windows环境变量下(KAFKA_HOME),并将其添加到path中(方法同上)
3.进入E:\midware\kafka_2.13-3.9.0,创建2个自定义文件夹mydata,mylog
4.修改zk的配置文件:
5、修改kafka的配置文件:
6、启动zk:
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
7、启动kafka:
bin\windows\kafka-server-start.bat config\server.properties
8、创建topic:
create:
bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --create --topic aaa --partitions 1
list:
bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092
delete:
bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic aaa
9、启动producer和consumer
在介绍启动producer和consumer的命令之前,先简单了解一下broker-list、bootstrap-servers和zookeeper。
1.broker:kafka服务端,可以是一个服务器也可以是一个集群。producer和consumer都相当于这个服务端的客户端。
2.broker-list:指定kafka集群中的一个或多个服务器,一般在使用kafka-console-producer.sh的时候,这个参数是必备参数,另外一个必备的参数是topic。
3.bootstrap-servers指的是kafka目标集群的服务器地址,这和broker-list功能一样,不过在启动producer时要求用broker-list,在启动consumer时用bootstrap-servers。
重新打开两个dos窗口,分别启动producer和consumer。
启动producer并输入内容:
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic aaa
启动consumer查看消息:
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic aaa--from-beginning
10、查看消费者组以及消息是否积压
查看消费者组的命令:
bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
查看某个消费者组的消息是否有积压的命令:
bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group 消费者组的名称
查看所有消费者组的消息是否有积压的命令:
#查看所有组的积压情况
bin/kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --all-groups
11、kafka可视化工具
https://www.kafkatool.com/download.html