ICheckpointManager.CreateCheckpointIfNotExistsAsync(String) Method

Definition

Namespace:

Microsoft.Azure.EventHubs.Processor

Assembly:

Microsoft.Azure.EventHubs.Processor.dll

Package:

Microsoft.Azure.EventHubs.Processor v4.3.2

Create the checkpoint for the given partition if it doesn't exist. Do nothing if it does exist. The offset/sequenceNumber for a freshly-created checkpoint should be set to StartOfStream/0.

public System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.Processor.Checkpoint> CreateCheckpointIfNotExistsAsync (string partitionId);

abstract member CreateCheckpointIfNotExistsAsync : string -> System.Threading.Tasks.Task<Microsoft.Azure.EventHubs.Processor.Checkpoint>

Public Function CreateCheckpointIfNotExistsAsync (partitionId As String) As Task(Of Checkpoint)

Parameters

partitionId

String

Id of partition to create the checkpoint for.

Returns

Task<Checkpoint>

The checkpoint for the given partition, whether newly created or already existing.