consumer_offset可以存partition的offset，当我消费完成之后会往这个consumer_offset加一条数据，那么，如果此时我重连回来，kafka怎么找到topic对应的offset给我，毕竟一个sonsumer_offset的partition数据那么多。
就是说，当出现了新的消费者接入的时候，他是怎样从这个consumer_offset_里面去找到对应的topic和partition，然后找到对应的offset出来。
参照这个 https://www.cnblogs.com/huxi2b/p/6061110.html
他存在这个_consumer_offset_所在的topic,里面使用了compact策略,使得它总是能够保存最新的位移信息。
所以你有兴趣可以看下这个策略的实现。
参照这个 https://www.cnblogs.com/huxi2b/p/6061110.html
他存在这个_consumer_offset_所在的topic,里面使用了compact策略,使得它总是能够保存最新的位移信息。
所以你有兴趣可以看下这个策略的实现。