kafka常用命令行命令

本文以windows演示

1) 首先将kafka安装包解压到本地，进入kafka目录 cd 

cd kafka_2.13-3.2.3\config

2) 启动kafka环境

zookeeper-server-start.bat zookeeper.properties (前提是kafka目录已加入环境变量)
kafka-server-start.bat server.properties  （另外打开一个终端）

3)创建一个主题topic
kafka-topics.bat --create --topic quickstart-events(topic名字) --bootstrap-server localhost:9092 （另外打开一个终端）

查看topic列表:

kafka-topics.bat --list --bootstrap-server localhost:9092  quickstart-events

kafka-topic.bat --bootstrap-server localhost:9092 --topic quickstart-events  --describe

生产者生成消息:

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

消费者消费消息:

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