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.