Reset consumer offset

This interface is exclusive for MQ Platinum edition users. For more information, go to Platinum Edition Purchase Page.

Description

This interface resets the consumer offset of the current Consumer ID to the specified time stamp according to the Consumer ID specified by the user. It’s used for clearing accumulated messages or tracing back consumption. It provides two methods: one is to clear all messages, and the other is to clear the consumption progress to the specified time.

Request parameters

Response parameters

Example

    public static void main(String []args) {
            String regionId = "cn-hangzhou";
            String accessKey = "XXXXXXXXXXXXXXXXX";
            String secretKey = "XXXXXXXXXXXXXXXXX";
            String endPointName ="cn-hangzhou";
            String productName ="Ons";
            String domain ="ons.cn-hangzhou.aliyuncs.com";
            /**
            *Select Region based on the region where you are located, and set the corresponding access point.
            */
            try {
                DefaultProfile.addEndpoint(endPointName,regionId,productName,domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId,accessKey,secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
            OnsConsumerResetOffsetRequest request = new OnsConsumerResetOffsetRequest();
            /**
            *OnsRegionId refers to the resource of the region of ONS required to be accessed by API.
            *This value must be selected and configured by the list obtained through the OnsRegionList method because OnsRegionId is changing, and cannot be written as a fixed value.
            */
            request.setOnsRegionId("daily");
            request.setPreventCache(System.currentTimeMillis());
            request.setAcceptFormat(FormatType.JSON);
            request.setConsumerId("CID_Mingduan");
            request.setTopic("MingduanTest");
            request.setType(1);
            request.setResetTimestamp(System.currentTimeMillis());
            try {
                OnsConsumerResetOffsetResponse response=iAcsClient.getAcsResponse(request);
                System.out.println(response.getRequestId());
            } catch (ServerException e) {
                e.printStackTrace();
            } catch (ClientException e) {
                e.printStackTrace();
            }
        }