0


Kafka中的偏移量消费问题_earliest和latest区别

auto.offset.reset这个参数的作用是:

1没有偏移量提交,针对的消费者的groupid对应的偏移量
2请求的的偏移量在broker上不存在时,会怎么消费kafka

如果满足上述1和2的情况:

  1. 当设置为earliest时,则会从该分区记录的位置开始消费,也就是这个命令获取的当前test这个topic的偏移量的位置: /kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -2
  2. 当设置为latest时,如果满足上述1和2的情况,则从当前时刻消费到的kafka数据开始消费

如果不满足上述1和2的情况:

则证明该消费者能识别到该topic的offset位置,则从识别到的offset位置开始消费数据。

标签: kafka 分布式

本文转载自: https://blog.csdn.net/weixin_45741411/article/details/137072939
版权归原作者 高耳机yyds 所有, 如有侵权,请联系我们删除。

“Kafka中的偏移量消费问题_earliest和latest区别”的评论:

还没有评论