EventProcessorClient.GetCheckpointAsync(String, CancellationToken) Método

Definición

Espacio de nombres:

Azure.Messaging.EventHubs

Ensamblado:

Azure.Messaging.EventHubs.Processor.dll

Paquete:

Azure.Messaging.EventHubs.Processor v5.11.3

Source:

EventProcessorClient.cs

Devuelve un punto de control para el centro de eventos, el grupo de consumidores y el identificador de partición asociados a la instancia del procesador de eventos, de modo que el procesamiento de una partición determinada se pueda inicializar correctamente.

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)

Parámetros

partitionId

String

Identificador de la partición para la que se va a recuperar el punto de control.

cancellationToken

CancellationToken

Instancia CancellationToken de para indicar la solicitud para cancelar el procesamiento. Esto es lo más probable que se produzca cuando el procesador se apague.

Devoluciones

Task<EventProcessorCheckpoint>

Punto de control del procesador que se debe tener en cuenta al inicializar la partición.

Comentarios

Si una partición no tiene un punto de control correspondiente, se aplicará la posición inicial predeterminada establecida por el PartitionInitializingAsync controlador. Si no se especificó ningún punto de partida específico de la partición, DefaultStartingPosition se usará para inicializar la partición para su procesamiento.