Adding a Checkpoint

Initialize a DIS client as instructed in Initializing a DIS SDK Client Instance.

Use the DIS SDK command to add a checkpoint.

string appName= "appName";
var dic = new DISIngestionClient();
         var request = new CommitCheckpointRequest
            {
//Stream name.
                stream_name = streamName,
//Application name.
                AppName = appName,
//Unique identifier of the partition.
                partition_id = "shardId-0000000000",
//Sequence number.
                sequence_number = "10",
//Metadata information of the consumer application.
                metadata = "metadata",
//Type of the checkpoint.
                checkpoint_type = "LAST_READ",
            };

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

Viewing Execution Results

Information similar to the following is displayed on the console:

{ResponseResult{status_code='201 Created', content='', errorCode='', message=''}}
Table 1 Description of response parameter ResponseResult

Parameter

Type

Description

content

String

Response body.

errorCode

String

Error code.

message

String

Error response body.

status_code

String

Status code.