档提供Kafka日常运维中常用的命令操作指南,帮助运维人员快速定位并解决问题。
1. 主题管理
- 创建主题:
kafka-topics.sh --bootstrap-server
--create --topic --partitions --replication-factor - 查看主题列表:
kafka-topics.sh --bootstrap-server
--list - 描述主题:
kafka-topics.sh --bootstrap-server
--describe --topic - 删除主题:
kafka-topics.sh --bootstrap-server
--delete --topic
2. 生产者操作
- 发送消息:
kafka-console-producer.sh --bootstrap-server
--topic - 查看消息:
kafka-console-consumer.sh --bootstrap-server
--topic --from-beginning
3. 消费者操作
- 创建消费者组:
kafka-consumer-groups.sh --bootstrap-server
--create --group --topic - 查看消费者组:
kafka-consumer-groups.sh --bootstrap-server
--describe --group - 删除消费者组:
kafka-consumer-groups.sh --bootstrap-server
--delete --group
4. 集群管理
- 查看集群信息:
kafka-cluster.sh --bootstrap-server
--describe - 查看broker信息:
kafka-broker-api.sh
注意: 以上命令中的
、
等需要替换成实际值。