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=''}} | Parameter | Type | Description |
|---|---|---|
| content | String | Response body. |
| errorCode | String | Error code. |
| message | String | Error response body. |
| status_code | String | Status code. |
Last Article: Deleting a Consumer Application
Next Article: Querying a Checkpoint
Did this article solve your problem?
Thank you for your score!Your feedback would help us improve the website.