文档首页 > > SDK参考> 使用SDK> 使用SDK(C#)> 查询CheckPoint

查询CheckPoint

分享
更新时间: 2019/05/07 GMT+08:00

参考初始化DIS客户端的操作初始化一个DIS客户端实例。

使用DIS SDK查询CheckPoint。

string streamName = “streamName”;
string appName= “appName”;
            var dic = new DISIngestionClient();
            var request = new GetCheckpointRequest
            {
               //通道名称
                StreamName = streamName,
               //应用ID
                AppId = appName,
              //分区的唯一标识符
                ShardId = "shardId-0000000000",
              //Checkpoint类型
                CheckpointType = "LAST_READ",
            };

            var response = dic.GetCheckpoint(request);
            Console.Out.WriteLine(response);

运行结果

可以在控制台查看到类似如下信息:

GetCheckpointResult [sequence_number=1,metadata=]
表1 GetCheckpointResult响应参数说明

参数名

类型

说明

sequence_number

String

序列号。序列号是每个记录的唯一标识符。

metadata

String

用户消费程序端的元数据信息。

分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问