Sdílet prostřednictvím

ICheckpointManager.CreateCheckpointIfNotExistsAsync(String) Method

  • Reference

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.

Applies to