CheckpointStore.GetCheckpointAsync Methode

Definition

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.dll

Paket:

Azure.Messaging.EventHubs v5.11.3

Quelle:

CheckpointStore.cs

Fordert Prüfpunktinformationen für eine bestimmte Partition an, sodass ein Ereignisprozessor das Lesen des nächsten Ereignisses im Stream fortsetzen kann.

public abstract System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, System.Threading.CancellationToken cancellationToken);

abstract member GetCheckpointAsync : string * string * string * string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint>

Public MustOverride Function GetCheckpointAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, partitionId As String, cancellationToken As CancellationToken) As Task(Of EventProcessorCheckpoint)

Parameter

fullyQualifiedNamespace

String

Der vollqualifizierte Event Hubs-Namespace, dem der Besitz zugeordnet ist. Dies ist wahrscheinlich ähnlich wie .{yournamespace}.servicebus.windows.net

eventHubName

String

Der Name des spezifischen Event Hubs, dem der Besitzer zugeordnet ist, relativ zum Event Hubs-Namespace, der ihn enthält.

consumerGroup

String

Der Name der Consumergruppe, der der Prüfpunkt zugeordnet ist.

partitionId

String

Der Bezeichner der Partition, für die ein Prüfpunkt gelesen werden soll.

cancellationToken

CancellationToken

Ein CancellationToken instance, um eine Anforderung zum Abbrechen des Vorgangs zu signalisieren.

Gibt zurück

Task<EventProcessorCheckpoint>

Ein EventProcessorCheckpoint instance, wenn ein Prüfpunkt für die angeforderte Partition gefunden wurde, nullandernfalls .