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

时间：2024-01-24 16:40:31

分布式消息服务KAFKA版实例使用类接口

请求参数

表2 参数说明
参数	类型	必选	说明
topic	String	是	topic名称。
partition	Integer	否	分区编号，默认值为-1，若传入值为-1，则重置所有分区。
message_offset	Long	二者必选其一	重置的消费进度到指定偏移量，如果传入offset小于当前最小的offset，则重置到最小的offset，如果大于最大的offset，则重置到最大的offset。
timestamp	Long	二者必选其一	重置的消费进度到指定时间，格式为unix时间戳。如果传入timestamp早于当前最早的timestamp，则重置到最早的timestamp，如果晚于最晚的timestamp，则重置到最晚的timestamp。

请求示例1

{
    "topic": "test",
    "partition": 0,
    "message_offset": 10
}

请求示例2

{
    "topic": "test",
    "partition": 0,
    "timestamp": 1571812144
}

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

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

7*24