重置消费者抵消额为kafka 0.10

Question

在0.10中,似乎我们可以使用seek()将偏移重置为特定位置

编写代码是否有一个命令行工具？到目前为止,它似乎不是这样吗？

Answer 1

我刚刚为此目的实现了一个简单的命令行工具 - https://github.com/serejja/kafka-offset-mgr。

请随意尝试并在必要时发布问题/PR。