文档首页 > > SDK参考> 使用SDK> 使用SDK(Java)> 查询Checkpoint

查询Checkpoint

分享
更新时间:2020/03/23 GMT+08:00

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

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

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"}
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问