- 查看当前消费组信息
./kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group es
-
使用重置脚本的前提是,消费组是非激活状态.
有2个执行选项:
--dry-run 生成计划
--execute 正则重置offset -
重置offset的范围可以通过参数指定:
to-datetime 按时间重置
to-earliest 重置到最早
--to-latest重置到最新
--to-current 重置到当前 -
消费组重置使用范围定义
--all-topics 所有topic
--topic 单个topic
./kafka-consumer-groups.sh --reset-offsets --to-latest --topic log-mobile-event --bootstrap-server localhost:9092 --group es --execute
网友评论