比如当前三条消息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去拉取的
比如当前三条消息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去拉取的
比如当前三条消息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去拉取的