0.10.1版本如何删除consumer的group和重置offset

之前用ZK管理可以直接修改消费组在每个分区上的offset,改用kafka管理后改不了了,网上说的方法发现自己版本的kafka-consumer-groups.sh没有--reset这个选项。。。
另外能直接删除掉整个group吗






发表于: 3月前   最后更新时间: 3月前   游览量:336
上一条: 到头了!
下一条: 已经是最后了!

  • --offset
    • 找了一圈,重置的命令都是下面2种,
      bin/kafka-consumer-groups.sh --bootstrap-server BORKER_HOST1:PORT1,BORKER_HSOT2:PORT2 --group GROUP_NAME --reset-offsets --execute --to-offset NEW_OFFSET --topic TOPIC_NAME
      bin/kafka-consumer-groups.sh --bootstrap-server BORKER_HOST1:PORT1,BORKER_HSOT2:PORT2 --group GROUP_NAME --reset-offsets --execute --to-earliest/--to-latest --topic TOPIC_NAME
      但我用的版本(2.11-0.10.1.0)执行时报“reset-offsets is not a recognized option”,“offset is not a recognized option”
      在使用kafka-console-consumer.sh时倒是可以使用--offset指定,但只能消费单个partition,不知道有没有其它可行的方法