auto.offset.reset这个参数的作用是:
1没有偏移量提交,针对的消费者的groupid对应的偏移量
2请求的的偏移量在broker上不存在时,会怎么消费kafka
如果满足上述1和2的情况:
- 当设置为earliest时,则会从该分区记录的位置开始消费,也就是这个命令获取的当前test这个topic的偏移量的位置: /kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -2
- 当设置为latest时,如果满足上述1和2的情况,则从当前时刻消费到的kafka数据开始消费
如果不满足上述1和2的情况:
则证明该消费者能识别到该topic的offset位置,则从识别到的offset位置开始消费数据。
本文转载自: https://blog.csdn.net/weixin_45741411/article/details/137072939
版权归原作者 高耳机yyds 所有, 如有侵权,请联系我们删除。
版权归原作者 高耳机yyds 所有, 如有侵权,请联系我们删除。