Partilhar via

EventProcessorClient.GetCheckpointAsync(String, CancellationToken) Método

  • Referência

Definição

Namespace:
Azure.Messaging.EventHubs
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Pacote:
Azure.Messaging.EventHubs.Processor v5.11.3
Pacote:
Azure.Messaging.EventHubs.Processor v5.12.0-beta.1
Origem:
EventProcessorClient.cs
Origem:
EventProcessorClient.cs

Retorna um ponto de verificação para o Hub de Eventos, o grupo de consumidores e a ID de partição associados à instância do processador de eventos, para que o processamento de uma determinada partição possa ser inicializado corretamente.

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

A ID da partição para a qual recuperar o ponto de verificação.

cancellationToken
CancellationToken

Uma CancellationToken instância para sinalizar a solicitação para cancelar o processamento. É mais provável que isso ocorra quando o processador está sendo desligado.

Retornos

Task<EventProcessorCheckpoint>

O ponto de verificação para o processador levar em conta ao inicializar a partição.

Comentários

Se uma partição não tiver um ponto de verificação correspondente, a posição inicial padrão definida pelo PartitionInitializingAsync manipulador será aplicada. Se nenhum ponto de partida específico da partição tiver sido especificado, o DefaultStartingPosition será usado para inicializar a partição para processamento.

Aplica-se a