1、集群启动

@echo off
echo %date% %time%,开始启动kafka集群！
start /b /d "server1/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server1/config/server.properties>> server1.log

start /b /d "server2/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server2/config/server.properties>> server2.log

start /b /d "server3/bin/windows" kafka-server-start.bat D:/development-software/kafka/cluster/server3/config/server.properties>> server3.log

2、创建主题

@echo off
echo 请输入要创建的主题名：
set /p topicName=
:start
echo 请输入分区数目：
set /p partitions=
echo 正在创建主题%topicName%...
start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --create --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster --replication-factor 3 --partitions %partitions% --topic %topicName%
echo 继续创建主题请输入主题名：
set /p topicName=
goto start
pause > nul

3、查看主题

@echo off
echo 正在查询主题列表...
start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --list --zookeeper localhost:2181/KafkaCluster
echo 请输入主题名称，若直接回车则视为查看所有主题详情：
set /p topicName=
echo 正在查询...
if  defined topicName (
start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster --topic %topicName%
) else (
start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-topics.bat --describe --zookeeper localhost:2181,localhost:2182,localhost:2183/KafkaCluster
)
pause > nul

4、查看消费组

@echo off
echo 正在查询消费者组列表...
start /wait /b /d "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --list

echo 请输入消费者组：
set /p group=

:start
echo 正在查询消费者组详情...
start /wait /b /d  "D:\development-software\kafka\cluster\server1\bin\windows" kafka-consumer-groups.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --describe --group %group%
echo 继续查看其他消费者组详情，请输入消费者组：
set /p group=
goto start

5、生产者

@echo off
echo 请输入生产者发布的主题：
set /p topicName=
./server1/bin/windows/kafka-console-producer.bat --broker-list localhost:9092,localhost:9093,localhost:9094 --topic %topicName% --producer.config ./server1/config/producer.properties

6、消费者

@echo off
echo 请输入消费者订阅的主题：
set /p topicName=
echo 请输入groupId：
set /p groupId=
echo 请输入clientId：
set /p clientId=
./server1/bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --topic %topicName% --from-beginning --consumer-property group.id=%groupId% client.id=%clientId%