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

图腾 发表于: 2019-01-16   最后更新时间: 2019-01-16 12:09:23   6,742 游览

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

kafka
发表于 2019-01-16
图腾
添加评论

--offset

回复
回答于 5年前
半兽人
图腾 -> 半兽人 5年前

找了一圈，重置的命令都是下面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，不知道有没有其它可行的方法

0 0 回复
节点。 -> 半兽人 4年前

请问我项目的groupid改了，我想把之前注册的删掉怎么删啊？kafka版本在1.0之上，所以在zookeeper客户端上删不掉，用

sh kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.51.108:9092 --group test-group1 --delete

这个命令也删不了。需要把之前的删掉吗？

0 0 回复
半兽人 -> 节点。 4年前

新版本的kafka，groupid的信息是当成主题存储的在__consumer_offsets中的，所以7天后（默认），会自动帮你清理的

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。