CheckpointStore Interface

Pacote:

com.azure.messaging.eventhubs

Artefato Maven:

com.azure:azure-messaging-eventhubs:5.18.4

public interface CheckpointStore

Uma interface que define as operações para armazenar e recuperar informações de propriedade da partição e detalhes do ponto de verificação para cada partição.

Resumo do método

Modificador e tipo	Método e descrição
abstract Flux<PartitionOwnership>	claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships) Chamado para reivindicar a propriedade de uma lista de partições.
abstract Flux<Checkpoint>	listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Chamado para obter a lista de pontos de verificação do armazenamento de dados subjacente.
abstract Flux<PartitionOwnership>	listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Chamado para obter a lista de toda a propriedade de partição existente do armazenamento de dados subjacente.
abstract Mono<Void>	updateCheckpoint(Checkpoint checkpoint) Atualizações o ponto de verificação no armazenamento de dados para uma partição.

Detalhes do método

claimOwnership

public abstract Flux claimOwnership(List requestedPartitionOwnerships)

Chamado para reivindicar a propriedade de uma lista de partições. Isso retornará a lista de partições que foram pertencentes com êxito.

Parameters:

requestedPartitionOwnerships - Lista de propriedades de partição que esta instância está solicitando para possuir.

Returns:

Um Flux de partições que essa instância reivindicou com êxito a propriedade.

listCheckpoints

public abstract Flux listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)

Chamado para obter a lista de pontos de verificação do armazenamento de dados subjacente. Esse método poderá retornar resultados vazios se não houver pontos de verificação disponíveis no armazenamento de dados.

Parameters:

fullyQualifiedNamespace - O namespace totalmente qualificado do Hub de Eventos.

eventHubName - O nome do Hub de Eventos para obter informações de ponto de verificação.

consumerGroup - O nome do grupo de consumidores associado ao ponto de verificação.

Returns:

Um Flux dos pontos de verificação associados às partições do Hub de Eventos.

listOwnership

public abstract Flux listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup)

Chamado para obter a lista de toda a propriedade de partição existente do armazenamento de dados subjacente. Pode retornar resultados vazios se não houver informações de propriedade existentes.

Parameters:

fullyQualifiedNamespace - O namespace totalmente qualificado do Hub de Eventos. É provável que isso seja semelhante a "{your-namespace}.servicebus.windows.net".

eventHubName - O nome do Hub de Eventos para obter informações de propriedade.

consumerGroup - O nome do grupo de consumidores.

Returns:

Um Flux de detalhes de propriedade de partição de todas as partições que têm/tinham um proprietário.

updateCheckpoint

public abstract Mono updateCheckpoint(Checkpoint checkpoint)

Atualizações o ponto de verificação no armazenamento de dados para uma partição.

Parameters:

checkpoint - Informações de ponto de verificação que contêm o número de sequência e o deslocamento a serem armazenados para essa partição.

Returns:

Um Mono que é concluído quando o ponto de verificação é atualizado.