更新时间:2024-10-25 GMT+08:00
查询Checkpoint
参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。
1 2 3 4 5 6 7 8 9 |
GetCheckpointRequest getCheckpointRequest = new GetCheckpointRequest(); // 设置App名称(注: 1.3.0及以前版本使用setAppId,1.3.1及后续版本请使用setAppName getCheckpointRequest.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的返回信息如下。
1 2 |
getCheckpoint: {"sequence_number": "10", "metadata": "metadata"} |
父主题: 使用SDK(Java)