在 kafka 0.10 中重置消费者偏移 [英] Reset consumer offset in kafka 0.10

问题描述

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

In 0.10 it seems we can reset the offset to a specific position with seek()

缺乏编写代码是否有用于此的命令行实用程序?到目前为止，似乎不是这样?

Short of writing code is there a command line util for this? It doesn't seem so, so far?

推荐答案

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

I've just implemented a simple command line tool for this purpose - https://github.com/serejja/kafka-offset-mgr.

如有必要，请随意尝试并发布问题/PR.

Feel free to try it out and post issues/PRs if necessary.

这篇关于在 kafka 0.10 中重置消费者偏移的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！