现在发现一个问题,我本地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");
你这设置里props.put("auto.offset.reset", "smallest"); 这个意思就是重头开始消费。注释掉试一试。。
发现问题了...谢谢...是因为我配置了props.put("auto.commit.enable", "false"); 不主动提交offsets 上面那个smallest是说在zookeeper中找不到offsets的时候从头开始消费吧!