分布式消息服务KAFKA版-重置消费组消费进度到指定位置:请求示例

时间:2024-01-24 16:40:18

请求示例

  • 重置的消费进度到指定偏移量。

    POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{group}/reset-message-offset
    
    {
      "topic" : "test",
      "partition" : 0,
      "message_offset" : 10
    }
  • 重置的消费进度到指定时间。

    POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{group}/reset-message-offset
    
    {
      "topic" : "test",
      "partition" : 0,
      "timestamp" : 1571812144000
    }
support.huaweicloud.com/api-kafka/ResetMessageOffsetWithEngine.html