CentOS 上管理 Kafka 消费者组
一 常用命令速览
| 目标 | 命令示例 |
|---|---|
| 列出所有消费者组 | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list |
| 查看消费组详情（含 LAG） | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group |
| 删除消费者组 | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group my-group |
| 重置消费位点（按时间） | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --alter --group my-group --topic my-topic --reset-offsets --to-datetime 2025-01-01T00:00:00Z --execute |
| 重置消费位点（到最早） | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --alter --group my-group --topic my-topic --reset-offsets --to-earliest --execute |
| 重置消费位点（到最新） | ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --alter --group my-group --topic my-topic --reset-offsets --to-latest --execute |
| 仅预览重置计划（不执行） | 将上条命令中的 –execute 替换为 –dry-run |
二 安全与连接配置
三 重置偏移量的要点与限制
四 监控与容量规划