Windows下进行kafka的命令行指令_kafka常用命令windows下

这里使用的是kafka_2.12-3.5.0

启动zookeeper

zkServer

启动kafka

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

创建topic

.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test(test是想要创建的topic的名字)

查看总topic

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

查看某一topic详细

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

创建生产者

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

创建消费者

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

退出kafka与zookeeper

.\bin\windows\kafka-server-stop.bat
.\bin\windows\zookeeper-server-stop.bat

删除topic（报错，kafka进程会直接结束）

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

在Windows下，因为在运行时不能对文件进行修改删除，所以，在Windows系统下建议手动删除，手动删除要在kafka所配置的log.dirs中的文件夹中将其删除，并且将zookeeper中zoo.cfg中的log.dir路径中的内容删除，求大佬的解决方式，真的不能自动删除吗，球球大佬们教教我