821      小米淨水器

重置消費位點__消費管理相關接口_Open API_消息隊列 MQ-阿裏雲

描述

根據用戶指定的訂閱組，將當前的訂閱組消費位點重置到指定時間戳。一般用於清理堆積消息，或者回溯消費。有2種方式，一種是清理所有消息，一種是清理消費進度到指定的時間。

請求參數

返回參數

使用示例

調用示例

    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";
            /**
            *根據自己所在的區域選擇Region後,設置對應的接入點
            */
            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是指你需要API訪問ONS哪個區域的資源。
            *該值必須要根據OnsRegionList方法獲取的列表來選擇和配置，因為OnsRegionId是變動的，不能夠寫固定值
            */
            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();
            }
        }

返回結果