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个回答

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

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

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐