kafka如何快速定位topic的offset

page contents

Pack 发布于 2020-02-20 20:53

阅读 707

答案 1

分类：中间件

consumer_offset可以存partition的offset，当我消费完成之后会往这个consumer_offset加一条数据，那么，如果此时我重连回来，kafka怎么找到topic对应的offset给我，毕竟一个sonsumer_offset的partition数据那么多。

就是说，当出现了新的消费者接入的时候，他是怎样从这个consumer_offset_里面去找到对应的topic和partition，然后找到对应的offset出来。

402

Pack 2020-02-20 20:53

参照这个 https://www.cnblogs.com/huxi2b/p/6061110.html

他存在这个_consumer_offset_所在的topic,里面使用了compact策略,使得它总是能够保存最新的位移信息。

所以你有兴趣可以看下这个策略的实现。

1 关注

提出于 2020-02-20 20:53

全部