- 启动Kafka：
kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties - 创建一个叫test的话题，有两个分区，每个分区3个副本：
kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 3 --partitions 2 - 查看创建的topic：
kafka-topics.sh --zookeeper localhost:2181 --list - 查看所有话题的详细信息：
kafka-topics.sh --zookeeper localhost:2181 --describe - 列出指定话题的详细信息：
kafka-topics.sh --zookeeper localhost:2181 --describe --topic test - 删除一个话题：
kafka-topics.sh --zookeeper localhost:2181 --delete --topic test - 生产消息：
kafka-console-producer --broker-list localhost:9092 --topic test1 - 消费消息：
kafka-console-consumer --bootstrap-server localhost:9092 --topic test1 --from-beginning加了–from-beginning 重头消费所有的消息，不加–from-beginning 从最新的一条消息开始消费 - 查看某个topic对应的消息数量：
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1 - 显示所有消费者：
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list - 获取正在消费的topic（console-consumer-63307）的group的offset：
kafka-consumer-groups.sh --describe --group console-consumer-63307 --bootstrap-server localhost:9092 - 停止Kafka：
kafka-server-stop.sh
Kafka：常用命令
2022-12-01 08:57:20
浏览数 (1)
