Kafka 消费者处理完一批消息后进程崩溃,位移(offset)尚未提交,重启后会发生什么?

中间件

  1. A.从崩溃处之后继续,这批消息永久丢失
  2. B.这批消息被重新消费,出现重复处理
  3. C.Kafka 自动补偿,不会重复也不会丢失
  4. D.该分区被永久锁定,需要人工介入