kafka1.1重置消费组命令

• 查看当前消费组信息

./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