PluggableCheckpointStoreEventProcessor<TPartition>.GetCheckpointAsync Método

Definição

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.dll

Pacote:

Azure.Messaging.EventHubs v5.11.3

Origem:

PluggableCheckpointStoreEventProcessor.cs

Retorna um ponto de verificação para o Hub de Eventos, o grupo de consumidores e o identificador da partição associada à 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

O identificador 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, o DefaultStartingPosition será usado para inicializar a partição para processamento.

Caso um ponto de partida personalizado seja desejado para uma única partição ou cada partição comece em um local exclusivo, é recomendável que esse método expresse essa intenção retornando pontos de verificação para essas partições com o conjunto de localização inicial personalizado desejado.