云服务器内容精选

实例使用类接口

分布式消息服务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版实例使用类接口