更新时间:2022-02-21 GMT+08:00
新创建的消费组从哪里开始消费?
- Kafka API
- 如果这个消费组是第一次启动消费,则会忽略之前发送的消息,也就是忽略历史消息,从启动之后发送的消息开始消费。如果需要从第一条消息开始消费,则在Kafka客户端的Consumer配置中,将auto.offset.reset的默认值“latest”改为“earliest”,即可以从队列中的第一条消息开始消费。
- 如果这个消费组是第二次启动消费,那么从上次消费的位置开始消费。
- 如果想从特定位置开始消费,可以通过DMS控制台的消费位点重置功能,指定到具体的时间开始消费。每次重置只针对特定消费组下的特定队列,不会影响其他Consumer ID。
- RESTful API / TCP API
- 如果这个消费组是第一次启动消费,则从队列中最早的消息开始消费。
- 如果这个消费组是第二次启动消费,那么从上次消费的位置开始消费。
- 如果想从特定位置开始消费,可以通过DMS控制台的消费位点重置功能,指定到具体的时间开始消费。每次重置只针对特定消费组下的特定队列,不会影响其他消费组。