Kafka常用命令速查

1. 主题 (Topic) 管理

说明	命令示例
创建 Topic	`bin/kafka-topics.sh --create \ --bootstrap-server localhost:9092 \ --replication-factor 1 \ --partitions 3 \ --topic my-topic`
查看所有 Topic	`bin/kafka-topics.sh --list \ --bootstrap-server localhost:9092`
查看 Topic 详情	`bin/kafka-topics.sh --describe \ --bootstrap-server localhost:9092 \ --topic my-topic`
修改 Topic (增加分区)	`bin/kafka-topics.sh --alter \ --bootstrap-server localhost:9092 \ --topic my-topic \ --partitions 5`
删除 Topic	`bin/kafka-topics.sh --delete \ --bootstrap-server localhost:9092 \ --topic my-topic`

2. 生产者与消费者 (Console)

说明	命令示例
启动控制台生产者	`bin/kafka-console-producer.sh \ --broker-list localhost:9092 \ --topic my-topic`
启动控制台消费者 (新版)	`bin/kafka-console-consumer.sh \ --bootstrap-server localhost:9092 \ --topic my-topic \ --from-beginning`
消费指定消费者组的数据	`bin/kafka-console-consumer.sh \ --bootstrap-server localhost:9092 \ --topic my-topic \ --group my-group`

3. 消费者组 (Consumer Group) 管理

说明	命令示例
列出所有消费者组	`bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --list`
查看消费者组详情 (Lag等)	`bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --describe \ --group my-group`
删除消费者组	`bin/kafka-consumer-groups.sh \ --bootstrap-server localhost:9092 \ --delete \ --group my-group`

4. 集群与其他管理

说明	命令示例
查看集群 Broker 信息	`bin/kafka-broker-api-versions.sh \ --bootstrap-server localhost:9092`
修改 Topic 配置 (如保留时间)	`bin/kafka-configs.sh \ --bootstrap-server localhost:9092 \ --entity-type topics \ --entity-name my-topic \ --alter \ --add-config retention.ms=3600000`