学习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
登录后复制
以上就是学会使用Kafka常用命令，灵活应对各种场景的学习必备的详细内容，更多请关注每日运维网(www.mryunwei.com)其它相关文章！
