• 启动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