风姿-懒人 2016-11-21 17:49 采纳率: 0%
浏览 7190

kafka consumer 提交offset 如何查看?

现在发现一个问题,我本地kafka消费了 但是却没有提交offset 导致每次一重启就重新开始消费!
请问哪位大神知道该如何查看我是否有提交offset 或者说怎么排查这个问题?我kafak consumer
配置如下:
props.put("zookeeper.session.timeout.ms", "10000");
props.put("zookeeper.connection.timeout.ms", "6000");
props.put("zookeeper.sync.time.ms", "2000");
props.put("auto.commit.interval.ms", "5000");
props.put("auto.offset.reset", "smallest");
props.put("auto.commit.enable", "false");

  • 写回答

2条回答 默认 最新

  • da cong ming 2016-11-22 18:28
    关注

    你这设置里props.put("auto.offset.reset", "smallest"); 这个意思就是重头开始消费。注释掉试一试。。

    评论
  • 风姿-懒人 2016-11-24 06:37
    关注

    发现问题了...谢谢...是因为我配置了props.put("auto.commit.enable", "false"); 不主动提交offsets 上面那个smallest是说在zookeeper中找不到offsets的时候从头开始消费吧!

    评论
编辑
预览

报告相同问题?

悬赏问题

  • ¥15 pycharm倒入虚拟环境的时候,显示这个,但是我的虚拟环境已经创建了
  • ¥15 FPGA芯片60进制计数器
  • ¥15 前端js怎么实现word的.doc后缀文件在线预览
  • ¥20 macmin m 4连接iPad
  • ¥15 DBIF_REPO_SQL_ERROR
  • ¥15 根据历年月数据,用Stata预测未来六个月汇率
  • ¥15 DevEco studio开发工具 真机联调找不到手机设备
  • ¥15 请教前后端分离的问题
  • ¥100 冷钱包突然失效,急寻解决方案
  • ¥15 下载honeyd时报错 configure: error: you need to instal a more recent version of libdnet
手机看
程序员都在用的中文IT技术交流社区

程序员都在用的中文IT技术交流社区

专业的中文 IT 技术社区,与千万技术人共成长

专业的中文 IT 技术社区,与千万技术人共成长

关注【CSDN】视频号,行业资讯、技术分享精彩不断,直播好礼送不停!

关注【CSDN】视频号,行业资讯、技术分享精彩不断,直播好礼送不停!

客服 返回
顶部