这家伙太懒,什么都没留下
这个只需存储最后的offset位置就好了,之前的offset存它没有意义的。
offset放在__consumer_offsets的topic里,需要的时候都从这个topic里从头读到尾?这样是否效率很低?
谢谢,也就是c1对应两个parttition,record会产生错乱。只保证来自同一个partition之间的record是保证顺序,不来自同一个partition的不保证顺序。
1、kafka是客户端维护的,0.9之后默认放在kafka的主题__consumer_offsets中,之前是在zk中。2、轮流拉取的,不会管时间戳的。
__consumer_offsets
请教两个个问题: