我使用的是kafka 0.10,我想知道是否有任何工具(来自/bin目录中提供的工具)可以用来将消费者的偏移量更改为特定位置?我已经看到我们可以通过JavaAPI(使用seek(…)方法)来完成,但是我找不到从命令行完成的方法。
muk1a3rh1#
0.11刚刚发布并添加了此重置功能您希望将kafka consumer groups命令与--reset offsets选项一起使用
1条答案
按热度按时间muk1a3rh1#
0.11刚刚发布并添加了此重置功能
您希望将kafka consumer groups命令与--reset offsets选项一起使用