学习Kafka必备：掌握常用命令，轻松应对各种场景
1. 创建Topic
bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2
2. 列出Topic
bin/kafka-topics.sh --list
3. 查看Topic详细信息
bin/kafka-topics.sh --describe --topic my-topic
4. 生产消息
bin/kafka-console-producer.sh --topic my-topic --message "Hello, Kafka!"
5. 消费消息
bin/kafka-console-consumer.sh --topic my-topic --from-beginning
6. 更改分区数量
bin/kafka-topics.sh --alter --topic my-topic --partitions 5
7. 更改副本数量
bin/kafka-topics.sh --alter --topic my-topic --replication-factor 3
8. 删除Topic
bin/kafka-topics.sh --delete --topic my-topic
9. 创建消费者组
bin/kafka-consumer-groups.sh --create --group my-group
10. 列出消费者组
bin/kafka-consumer-groups.sh --list
11. 查看消费者组详细信息
bin/kafka-consumer-groups.sh --describe --group my-group
12. 将消费者加入消费者组
bin/kafka-consumer-groups.sh --join --group my-group --topic my-topic
13. 将消费者从消费者组中移除
bin/kafka-consumer-groups.sh --leave --group my-group --topic my-topic
14. 删除消费者组
bin/kafka-consumer-groups.sh --delete --group my-group
15. 获取Topic的偏移量
bin/kafka-run-class kafka.tools.GetOffsetShell --topic my-topic --group my-group
16. 设置Topic的偏移量
bin/kafka-run-class kafka.tools.OffsetResetTool --topic my-topic --group my-group --to-earliest
17. 监控Kafka集群
bin/kafka-server-start.sh --daemon --console
18. 关闭Kafka集群
bin/kafka-server-stop.sh
19. 诊断Kafka集群
bin/kafka-run-class kafka.tools.JmxTool --query "kafka.server:type=*,name=*,clientId=*"
20. 导出Kafka集群的配置
bin/kafka-run-class kafka.tools.DumpLogSegments --print-data --source /tmp/kafka-logs
21. 导入Kafka集群的配置
bin/kafka-run-class kafka.tools.LoadLogSegments --source /tmp/kafka-logs
22. 升级Kafka集群
bin/kafka-upgrade-kafka.sh --target-version 3.0.0
23. 降级Kafka集群
bin/kafka-downgrade-kafka.sh --target-version 2.8.0
