如何手动更新Kafka中某个Topic的偏移量
2016-08-31 23:29
344 查看
本文介绍如何手动跟新zookeeper中的偏移量。我们在使用kafka的过程中,有时候需要通过修改偏移量来进行重新消费。我们都知道offsets是记录在zookeeper中的,所以我们想修改offsets的值只要修改zookeeper中的offsets值就可以了。修改offsets值有几种方法,这里介绍最直接的一种修改方法,就是直接手动修改zookeeper中记录的offsets值。
首先进入zk客户端
zkCli.sh -server localhost:2181
Offsets值记录在zk客户端具体的路径为
/consumers/[group
4000
Id]/offsets/[topic]/[partitionId]
比如查看test3主题0分区下的offsets
[zk: localhost:42182(CONNECTED) 22] get /consumers/group1/offsets/test3/0
![](https://img-blog.csdn.net/20160831233002265?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
Offsets=215161
然后修改你想要修改的哪个topic下的哪个partition的offsets就可以了。
修改test3主题0分区下的offsets值为100
![](https://img-blog.csdn.net/20160831233013500?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
这样就修改了Offsets
我们再用上诉命令查看一下Offsets
查看test3主题0分区下的offsets
[zk: localhost:42182(CONNECTED) 22] get /consumers/group1/offsets/test3/0
![](https://img-blog.csdn.net/20160831233100858?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center)
Offsets=100
修改完大家再重新消费一下就会发现已经可以消费出以前的数据了。
想了解关于重新消费问题可以关注本博客其他文章
首先进入zk客户端
zkCli.sh -server localhost:2181
Offsets值记录在zk客户端具体的路径为
/consumers/[group
4000
Id]/offsets/[topic]/[partitionId]
比如查看test3主题0分区下的offsets
[zk: localhost:42182(CONNECTED) 22] get /consumers/group1/offsets/test3/0
Offsets=215161
然后修改你想要修改的哪个topic下的哪个partition的offsets就可以了。
修改test3主题0分区下的offsets值为100
这样就修改了Offsets
我们再用上诉命令查看一下Offsets
查看test3主题0分区下的offsets
[zk: localhost:42182(CONNECTED) 22] get /consumers/group1/offsets/test3/0
Offsets=100
修改完大家再重新消费一下就会发现已经可以消费出以前的数据了。
想了解关于重新消费问题可以关注本博客其他文章
相关文章推荐
- 如何手动更新Kafka中某个Topic的偏移量
- Exchange帐号如何手动更新?
- 如何利用ClickOnce布署进行手动在线更新
- 如何手动更新Joomla!
- ntp如何手动更新时间
- kafka源码解析之十七消费者流程(客户端如何获取topic的数据)
- 如何利用ClickOnce布署进行手动在线更新
- Kafka如何创建topic?
- linux下如何手动更新Firefox
- 买家手动关闭了返回页面,交易订单如何更新?
- 如何手动更新NetBeans7的hibernate类库的版本
- (场景)kafka的topic多分区的情况,如何保证跨区的消息消费的顺序性
- 如何使用 .jdb 文件手动更新 Symantec Endpoint Protection Manager 的病毒定义
- java api如何获取kafka所有Topic列表,并放置为一个list
- 如何在Kafka上对一个Topic增加partition
- 如何让ClickOnce进行手动更新
- 如何在Kafka中对Topic的leader进行均衡
- 如何在Kafka上对一个Topic增加replicas
- kafka源码解析之十五客户端如何创建topic
- Kafka如何动态增加Topic的副本(Replication)