数据接入服务 DIS-查询Checkpoint

时间:2025-01-26 10:36:48

查询Checkpoint

参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。

其中,“streamName”的配置值要与开通DIS通道中“通道名称”的值一致,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参见获取认证信息

123456789
GetCheckpointRequest getCheckpointRequest = new GetCheckpointRequest();// 设置App名称(注: 1.3.0及以前版本使用setAppId,1.3.1及后续版本请使用setAppNamegetCheckpointRequest.setAppName(appName);getCheckpointRequest.setStreamName(streamName);// 分区编号getCheckpointRequest.setPartitionId("0");// Checkpoint类型getCheckpointRequest.setCheckpointType(CheckpointTypeEnum.LAST_READ.name());System.out.println("getCheckpoint: " + JsonUtils.objToJson(dic.getCheckpoint(getCheckpointRequest)));

查询Checkpoint的返回信息如下。

12
getCheckpoint:{"sequence_number": "10", "metadata": "metadata"}
support.huaweicloud.com/sdkreference-dis/dis_06_0509.html