现在发现一个问题,我本地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条回答 默认 最新
悬赏问题
- ¥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