Partager via

BlobCheckpointStore.UpdateCheckpointAsync Méthode

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paquet:
Azure.Messaging.EventHubs.Processor v5.10.0

Crée ou met à jour un point de contrôle pour une partition spécifique, en identifiant une position dans le flux d’événements de la partition à partir de laquelle un processeur d’événements doit commencer la lecture.

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

Paramètres

fullyQualifiedNamespace
String

Espace de noms Event Hubs complet à lequel la propriété est associée. Cela est susceptible d’être similaire à {yournamespace}.servicebus.windows.net.

eventHubName
String

Nom du hub d’événements spécifique auquel la propriété est associée, par rapport à l’espace de noms Event Hubs qui le contient.

consumerGroup
String

Nom du groupe de consommateurs auquel le point de contrôle est associé.

partitionId
String

Identificateur de la partition pour laquelle le point de contrôle est destiné.

offset
Int64

Décalage à associer au point de contrôle, indiquant qu’un processeur doit commencer à lire l’événement suivant dans le flux.

sequenceNumber
Nullable<Int64>

Numéro de séquence facultatif à associer au point de contrôle, destiné à être des métadonnées d’information. le offset sera utilisé pour le positionnement lors de la lecture des événements.

cancellationToken
CancellationToken

Un CancellationToken instance pour signaler une demande d’annulation de l’opération.

Retours

Task

S’applique à