kafka执行shell重置消费组的offset为最新的
时间: 2024-03-30 09:37:02 浏览: 236
可以使用 `kafka-consumer-groups.sh` 脚本来重置消费组的 offset 为最新的。具体操作如下:
1. 打开一个终端窗口,进入 Kafka 的 bin 目录下,执行以下命令:
```
./kafka-consumer-groups.sh --bootstrap-server <kafka_broker_list> --group <consumer_group_name> --reset-offsets --to-latest --all-topics --execute
```
其中,`<kafka_broker_list>` 是 Kafka 集群的 broker 列表,`<consumer_group_name>` 是待重置 offset 的消费组名。
2. 等待脚本执行完毕即可。执行成功后,消费组的 offset 将被重置为最新的。
阅读全文