BlobCheckpointStore.GetCheckpointAsync Método

Definição

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Pacote:

Azure.Messaging.EventHubs.Processor v5.11.3

Origem:

BlobCheckpointStore.cs

Solicita informações de ponto de verificação para uma partição específica, permitindo que um processador de eventos retome a leitura do próximo evento no fluxo.

public override System.Threading.Tasks.Task<Azure.Messaging.EventHubs.Primitives.EventProcessorCheckpoint> GetCheckpointAsync (string fullyQualifiedNamespace, string eventHubName, string consumerGroup, string partitionId, System.Threading.CancellationToken cancellationToken);

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

Public Overrides Function GetCheckpointAsync (fullyQualifiedNamespace As String, eventHubName As String, consumerGroup As String, partitionId As String, cancellationToken As CancellationToken) As Task(Of EventProcessorCheckpoint)

Parâmetros

fullyQualifiedNamespace

String

O namespace dos Hubs de Eventos totalmente qualificado ao qual a propriedade está associada. É provável que isso seja semelhante a {yournamespace}.servicebus.windows.net.

eventHubName

String

O nome do Hub de Eventos específico ao qual a propriedade está associada, em relação ao namespace dos Hubs de Eventos que o contém.

consumerGroup

String

O nome do grupo de consumidores ao qual o ponto de verificação está associado.

partitionId

String

O identificador da partição para a qual ler um ponto de verificação.

cancellationToken

CancellationToken

Uma CancellationToken instância para sinalizar uma solicitação para cancelar a operação.

Retornos

Task<EventProcessorCheckpoint>

Uma EventProcessorCheckpoint instância, se um ponto de verificação foi encontrado para a partição solicitada; caso contrário, null.