白云飞

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 白云飞kafka入门介绍 中 :

    这个只需存储最后的offset位置就好了,之前的offset存它没有意义的。

    3年前
  • 白云飞 回复 半兽人kafka入门介绍 中 :

    offset放在__consumer_offsets的topic里,需要的时候都从这个topic里从头读到尾?这样是否效率很低?

    3年前
  • 白云飞 回复 半兽人kafka入门介绍 中 :

    谢谢,也就是c1对应两个parttition,record会产生错乱。只保证来自同一个partition之间的record是保证顺序,不来自同一个partition的不保证顺序。

    3年前
  • 半兽人 回复 白云飞kafka入门介绍 中 :

    1、kafka是客户端维护的,0.9之后默认放在kafka的主题__consumer_offsets中,之前是在zk中。
    2、轮流拉取的,不会管时间戳的。

    3年前
  • 白云飞 回复 半兽人kafka入门介绍 中 :

    请教两个个问题:

    1. offset由客户维护吧? 存在内存中,还是还是序列化到磁盘?如果存在磁盘用什么,kafka吗?
    2. Server有p1,p2,p3,p4分区,consumer group有c1(对应p1,p2),c2(对应p3,p4)。c1分别从p1和p2读到两个recorde,需要判断下谁的时间戳新旧,旧的先处理?
    3年前