分布式消息服务 DMS分布式消息服务 DMS

文档首页> 分布式消息服务 DMS> 常见问题(仅存量用户使用)> 新创建的消费组从哪里开始消费?
更新时间:2021/06/16 GMT+08:00
分享

新创建的消费组从哪里开始消费?

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

    相关文档

    相关产品