kafka查询和修改topic的offset
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka查询和修改topic的offset相关的知识，希望对你有一定的参考价值。
参考技术A 输出输出
注意如果你的kafka设置了zookeeper root，比如为/kafka，那么命令应该改为：
重启相关的应用程序，就可以从设置的offset开始读数据了。
手动更新Kafka存在Zookeeper中的偏移量。我们有时候需要手动将某个主题的偏移量设置成某个值，这时候我们就需要更新Zookeeper中的数据了。Kafka内置为我们提供了修改偏移量的类：kafka.tools.UpdateOffsetsInZK，我们可以通过它修改Zookeeper中某个主题的偏移量，具体操作如下：
在不输入参数的情况下，我们可以得知kafka.tools.UpdateOffsetsInZK类需要输入的参数。我们的consumer.properties文件配置内容如下：
这个工具只能把Zookeeper中偏移量设置成earliest或者latest，如下：
以上是关于kafka查询和修改topic的offset的主要内容，如果未能解决你的问题，请参考以下文章
华为kafka安全版重置group中的topic offset不生效问题
how to read from __consumer_offsets topic