EventProcessor<TPartition>.GetCheckpointAsync Método

Referência

Definição

Namespace:: Azure.Messaging.EventHubs.Primitives

Assembly:: Azure.Messaging.EventHubs.dll

Pacote:: Azure.Messaging.EventHubs v5.11.3

Pacote:: Azure.Messaging.EventHubs v5.12.0-beta.1

Origem:: EventProcessor.cs

Origem:: EventProcessor.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

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. A implementação padrão chama e filtra os Azure.Messaging.EventHubs.Primitives.EventProcessor`1.ListCheckpointsAsync(System.Threading.CancellationToken) resultados por PartitionId. É recomendável que esse método seja substituído em EventProcessor<TPartition> implementações para obter um desempenho ideal.

protected virtual System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string partitionId, System.Threading.CancellationToken cancellationToken);

abstract member GetCheckpointAsync : string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint>
override this.GetCheckpointAsync : string * System.Threading.CancellationToken -> System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint>

Protected Overridable 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.

No caso de um ponto de partida personalizado ser desejado para uma única partição ou cada partição deve começar 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.

Aplica-se a

Compartilhar via