档提供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

注意: 以上命令中的 等需要替换成实际值。