Chinaunix首页 | 论坛 | 博客
  • 博客访问: 4229825
  • 博文数量: 447
  • 博客积分: 1241
  • 博客等级: 中尉
  • 技术积分: 5786
  • 用 户 组: 普通用户
  • 注册时间: 2011-01-27 06:48
个人简介

读好书,交益友

文章分类

全部博文(447)

文章存档

2024年(1)

2023年(5)

2022年(29)

2021年(49)

2020年(16)

2019年(15)

2018年(23)

2017年(67)

2016年(42)

2015年(51)

2014年(57)

2013年(52)

2012年(35)

2011年(5)

分类: Java

2016-09-19 14:38:05

格式 topic:partitionId:offset
查询最小值
 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 -topic alert2 --time -29092 
alert2:0:


查询最大值
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 -topic alert2 --time -1
alert2:0:187785423
设置offset
bin/zookeeper-shell.sh 127.0.0.1:2181
set /consumers/{yourConsumerGroup}/offsets/{yourFancyTopic}/{partitionId} {newOffset}

阅读(1951) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~