当前位置： 文江博客话题详情

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

发布于 2021-12-01 10:57:54 字数 55 浏览 907 评论 4

如题，怎么用Java代码在consumer端，手动设置消息offset  
 commit

如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论， 你可以免费 注册 一个本站的账号。

评论（4）

残花月 2021-12-04 18:53:09

手动 commit 知道 ，但是手动 自定义 commit offset 就不知道了

回复
无人问我粥可暖 2021-12-04 13:39:58

可以参考下 StormSpout的方法 把offset写到zookeeper里面 或者数据库也行

回复
水水月牙 2021-12-01 15:32:12

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

回复
~没有更多了~

关于作者

画骨成沙

暂无简介

0 文章
0 评论
794 人气
发私信

相关话题

更多

热门标签

操作系统 程序设计 IT运维 Linux系统管理 JavaScript 服务器应用 solaris C/C++ PHP Shell BSD Vue.js aix Oracle Python HTML 系统管理 HTML5 CSS 前端
更多

推荐作者

苦中寻乐

文章 0 评论 0

lueluelue

文章 0 评论 0

嗼ふ静

文章 0 评论 0

王权女流氓

文章 0 评论 0

与花如笺

文章 0 评论 0

残酷

文章 0 评论 0

更多

友情链接

文江博客
    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站，即表示您同意使用 Cookies 和您的相关数据。
    原文