如题,怎么用Java代码在consumer端,手动设置消息offset commit
手动 commit 知道 ,但是手动 自定义 commit offset 就不知道了
君枫 新版我也没看到怎么用
可以参考下 StormSpout的方法 把offset写到zookeeper里面 或者数据库也行
老版(Scala)消费者是不支持的(0.8.x及其以下),新版(Java)客户端是支持的,0.9.x~0.10.x
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
暂无简介
文章 0 评论 0
接受
发布评论
评论(4)
手动 commit 知道 ,但是手动 自定义 commit offset 就不知道了
君枫 新版我也没看到怎么用
可以参考下 StormSpout的方法 把offset写到zookeeper里面 或者数据库也行
老版(Scala)消费者是不支持的(0.8.x及其以下),新版(Java)客户端是支持的,0.9.x~0.10.x