本文介绍了在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中重置使用者偏移量的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

08-05 00:51