返回到文章
优化问题排版

采纳

编辑于 3年前

kafka消费者消息不提交确认是如何拉取新的消息的?

比如当前三条消息A B C

consumerOffset=0 lag=3 消费者1 分区A

消费者1消费消息A 并且提交确认后,数据变化如下

consumerOffset=1 lag=2 消费者1 分区A

消费者1消费消息B,但不提交确认,此处出现疑问了

1、数据变化还是consumerOffset=1 lag=2 消费者1 分区A吗

2、消费者1怎么保存自身当前消费的offset的,此当前消费的offset应该是和consumerOffset的值不一致的,然后会继续拉取消息C,怎么获取到消息C的offset去拉取的

kafka消费者消息不提交确认是如何拉取消息的

比如当前三条消息A B C
consumerOffset=0 lag=3 消费者1 分区A
消费者1消费消息A 并且提交确认后 数据变化如下
consumerOffset=1 lag=2 消费者1 分区A
消费者1消费消息B 不提交确认 此处出现疑问了
1.数据变化还是consumerOffset=1 lag=2 消费者1 分区A吗
2.消费者1怎么保存自身当前消费的offset的,此当前消费的offset应该是和consumerOffset的值不一致的,
然后会继续拉取消息C,怎么获取到消息C的offset去拉取的

记录

编辑于 3年前

kafka消费者消息不提交确认是如何拉取消息的

kafka

比如当前三条消息A B C
consumerOffset=0 lag=3 消费者1 分区A
消费者1消费消息A 并且提交确认后 数据变化如下
consumerOffset=1 lag=2 消费者1 分区A
消费者1消费消息B 不提交确认 此处出现疑问了
1.数据变化还是consumerOffset=1 lag=2 消费者1 分区A吗
2.消费者1怎么保存自身当前消费的offset的,此当前消费的offset应该是和consumerOffset的值不一致的,
然后会继续拉取消息C,怎么获取到消息C的offset去拉取的