图腾

0 声望

这家伙太懒,什么都没留下

个人动态
  • 图腾 回复 半兽人0.10.1版本如何删除consumer的group和重置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,不知道有没有其它可行的方法

    5年前