BlobCheckpointStore.UpdateCheckpointAsync Methode

  • Referenz

Definition

Namespace:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paket:
Azure.Messaging.EventHubs.Processor v5.10.0

Erstellt oder aktualisiert einen Prüfpunkt für eine bestimmte Partition, um eine Position im Ereignisstream der Partition zu identifizieren, von der ein Ereignisprozessor mit dem Lesen beginnen soll.

public override System.Threading.Tasks.Task UpdateCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, long offset, long? sequenceNumber, System.Threading.CancellationToken cancellationToken);
override this.UpdateCheckpointAsync : string * string * string * string * int64 * Nullable<int64> * System.Threading.CancellationToken -> System.Threading.Tasks.Task
Public Overrides Function UpdateCheckpointAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, partitionId As String, offset As Long, sequenceNumber As Nullable(Of Long), cancellationToken As CancellationToken) As Task

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 Besitz 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 der Prüfpunkt verwendet wird.

offset
Int64

Der Offset, der dem Prüfpunkt zugeordnet werden soll, der angibt, dass ein Prozessor mit dem Lesen des nächsten Ereignisses im Stream beginnen soll.

sequenceNumber
Nullable<Int64>

Eine optionale Sequenznummer, die dem Prüfpunkt zugeordnet werden soll und als Informationsmetadaten vorgesehen ist. Wird offset für die Positionierung verwendet, wenn Ereignisse gelesen werden.

cancellationToken
CancellationToken

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

Gibt zurück

Task

Gilt für: