CheckpointStore Interface

Paquet:

com.azure.messaging.eventhubs

Artefact Maven:

com.azure:azure-messaging-eventhubs:5.18.4

public interface CheckpointStore

Interface qui définit les opérations de stockage et de récupération des informations de propriété de partition et des détails de point de contrôle pour chaque partition.

Résumé de la méthode

Modificateur et type	Méthode et description
abstract Flux<PartitionOwnership>	claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships) Appelé pour revendiquer la propriété d’une liste de partitions.
abstract Flux<Checkpoint>	listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Appelé pour obtenir la liste des points de contrôle à partir du magasin de données sous-jacent.
abstract Flux<PartitionOwnership>	listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Appelé pour obtenir la liste de toutes les propriétés de partition existantes à partir du magasin de données sous-jacent.
abstract Mono<Void>	updateCheckpoint(Checkpoint checkpoint) Mises à jour le point de contrôle dans le magasin de données d’une partition.

Détails de la méthode

claimOwnership

public abstract Flux claimOwnership(List requestedPartitionOwnerships)

Appelé pour revendiquer la propriété d’une liste de partitions. Cela retourne la liste des partitions qui ont été détenues avec succès.

Parameters:

requestedPartitionOwnerships - Liste des propriétés de partition que cette instance demande à posséder.

Returns:

De Flux partitions que cette instance la propriété a réussi à revendiquer la propriété.

listCheckpoints

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

Appelé pour obtenir la liste des points de contrôle à partir du magasin de données sous-jacent. Cette méthode peut retourner des résultats vides si aucun point de contrôle n’est disponible dans le magasin de données.

Parameters:

fullyQualifiedNamespace - Espace de noms complet du hub d’événements.

eventHubName - Nom du hub d’événements pour obtenir des informations de point de contrôle.

consumerGroup - Nom du groupe de consommateurs associé au point de contrôle.

Returns:

de Flux points de contrôle associés aux partitions d’Event Hub.

listOwnership

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

Appelé pour obtenir la liste de toutes les propriétés de partition existantes à partir du magasin de données sous-jacent. Peut retourner des résultats vides s’il n’existe aucune information de propriété existante.

Parameters:

fullyQualifiedNamespace - Espace de noms complet du hub d’événements. Cela est susceptible d’être similaire à « {votre-espace de noms}.servicebus.windows.net ».

eventHubName - Nom du hub d’événements pour obtenir des informations de propriété.

consumerGroup - Nom du groupe de consommateurs.

Returns:

des Flux détails de la propriété de la partition de toutes les partitions qui ont/ont un propriétaire.

updateCheckpoint

public abstract Mono updateCheckpoint(Checkpoint checkpoint)

Mises à jour le point de contrôle dans le magasin de données d’une partition.

Parameters:

checkpoint - Informations de point de contrôle contenant le numéro de séquence et le décalage à stocker pour cette partition.

Returns:

Mono qui se termine lorsque le point de contrôle est mis à jour.