kafka consumer offset 怎么用java代码手动设置commit

bolean 发布于 2016/06/14 11:03
阅读 1K+
收藏 0
如题,怎么用Java代码在consumer端,手动设置消息offset   commit
加载中
0
君枫
君枫

老版(Scala)消费者是不支持的(0.8.x及其以下),新版(Java)客户端是支持的,0.9.x~0.10.x

0
沧海_Sea
沧海_Sea
可以参考下 StormSpout的方法 把offset写到zookeeper里面 或者数据库也行
0
RealMatrix
RealMatrix
手动 commit 知道 ,但是手动 自定义 commit offset 就不知道了
返回顶部
顶部