PluggableCheckpointStoreEventProcessor<TPartition>.GetCheckpointAsync Methode

Referenz

Definition

Namespace:: Azure.Messaging.EventHubs.Primitives

Assembly:: Azure.Messaging.EventHubs.dll

Paket:: Azure.Messaging.EventHubs v5.11.3

Paket:: Azure.Messaging.EventHubs v5.12.0-beta.1

Quelle:: PluggableCheckpointStoreEventProcessor.cs

Quelle:: PluggableCheckpointStoreEventProcessor.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Gibt einen Prüfpunkt für den Event Hub, die Consumergruppe und den Bezeichner der Partition zurück, die dem Ereignisprozessor instance zugeordnet ist, sodass die Verarbeitung für eine bestimmte Partition ordnungsgemäß initialisiert werden kann.

protected override System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string partitionId, System.Threading.CancellationToken cancellationToken);

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

Protected Overrides Function GetCheckpointAsync (partitionId As String, cancellationToken As CancellationToken) As Task(Of EventProcessorCheckpoint)

Parameter

partitionId: String

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

cancellationToken: CancellationToken

Ein CancellationToken instance, um die Anforderung zum Abbrechen der Verarbeitung zu signalisieren. Dies tritt am wahrscheinlichsten auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<EventProcessorCheckpoint>

Der Prüfpunkt, den der Prozessor beim Initialisieren der Partition berücksichtigen soll.

Hinweise

Sollte eine Partition nicht über einen entsprechenden Prüfpunkt verfügen, wird der DefaultStartingPosition verwendet, um die Partition für die Verarbeitung zu initialisieren.

Für den Fall, dass ein benutzerdefinierter Startpunkt für eine einzelne Partition gewünscht ist oder jede Partition an einer eindeutigen Stelle beginnen sollte, empfiehlt es sich, diese Absicht auszudrücken, indem Prüfpunkte für diese Partitionen mit dem gewünschten benutzerdefinierten Startort zurückgegeben werden.

Gilt für:

Freigeben über