Iyxh

0 声望

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

个人动态
  • 发表了 Kafka有关poll方法的疑问  
    5年前
  • Iyxh 回复 半兽人 在 Kafka有关Poll方法的疑问 中 ：

    好的，感谢

    5年前
  • 半兽人 回复 Iyxh 在 Kafka有关Poll方法的疑问 中 ：

    嗯，是的

    5年前
  • Iyxh 回复 半兽人 在 Kafka有关Poll方法的疑问 中 ：

    不管是自动提交还是手动提交，实际上都是只有第一次才是从consumer_offset获取吗

    5年前
  • 半兽人 回复 Iyxh 在 Kafka有关Poll方法的疑问 中 ：

    第一次是从consumer_topic获取，之后就是客户端自己维护offset位置了，而不是服务器控制的。

    5年前
  • Iyxh 回复 半兽人 在 Kafka有关Poll方法的疑问 中 ：

    关于第二点，我有个疑问。poll的时候，会带上我需要的offset，这个offsets是从哪里获取的。

    因为我以前一直觉得这个offsets是从kafka的consumer_offsets中获取的。但是通过这个案例我觉得可能并非是从consumer_offsets中获取的，倘若每次poll都是从consumer_topic，由于没有提交offsets，按道理应该是每次都会获取到重复数据，而非需要重新启动消费者程序。

    而客户端本身会缓存这个offsets位置，我可以理解为只有第一次poll的时候才从consumer_offsets中获取offsets，后续的操作从客户端本身维护的offsets来进行获取消息的吗？采用本身缓存offsets而非从consumer_offsets，这样做的好处是什么呢，减少请求吗？

    5年前
  • 发表了 Kafka有关Poll方法的疑问  
    5年前