CheckpointStore Interfaz

Paquete:

com.azure.messaging.eventhubs

Artefacto Maven:

com.azure:azure-messaging-eventhubs:5.18.4

public interface CheckpointStore

Interfaz que define las operaciones para almacenar y recuperar la información de propiedad de partición y los detalles del punto de control de cada partición.

Resumen del método

Modificador y tipo	Método y descripción
abstract Flux<PartitionOwnership>	claimOwnership(List<PartitionOwnership> requestedPartitionOwnerships) Se llama para reclamar la propiedad de una lista de particiones.
abstract Flux<Checkpoint>	listCheckpoints(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Se llama a para obtener la lista de puntos de control del almacén de datos subyacente.
abstract Flux<PartitionOwnership>	listOwnership(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Se llama para obtener la lista de toda la propiedad de partición existente del almacén de datos subyacente.
abstract Mono<Void>	updateCheckpoint(Checkpoint checkpoint) Novedades el punto de control en el almacén de datos de una partición.

Detalles del método

claimOwnership

public abstract Flux claimOwnership(List requestedPartitionOwnerships)

Se llama para reclamar la propiedad de una lista de particiones. Esto devolverá la lista de particiones que se han propiedaddo correctamente.

Parameters:

requestedPartitionOwnerships - Lista de las propiedades de partición que esta instancia solicita poseer.

Returns:

Una Flux de las particiones de esta instancia ha reclamado correctamente la propiedad.

listCheckpoints

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

Se llama a para obtener la lista de puntos de control del almacén de datos subyacente. Este método podría devolver resultados vacíos si no hay puntos de control disponibles en el almacén de datos.

Parameters:

fullyQualifiedNamespace - Espacio de nombres completo del centro de eventos.

eventHubName - Nombre del centro de eventos para obtener información de punto de control.

consumerGroup - Nombre del grupo de consumidores asociado al punto de control.

Returns:

De Flux puntos de control asociados a las particiones del centro de eventos.

listOwnership

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

Se llama para obtener la lista de toda la propiedad de partición existente del almacén de datos subyacente. Podría devolver resultados vacíos si no hay información de propiedad existente.

Parameters:

fullyQualifiedNamespace - Espacio de nombres completo del centro de eventos. Es probable que sea similar a "{your-namespace}.servicebus.windows.net".

eventHubName - Nombre del centro de eventos para obtener información de propiedad.

consumerGroup - Nombre del grupo de consumidores.

Returns:

Un Flux de detalles de propiedad de partición de todas las particiones que tienen o tenían un propietario.

updateCheckpoint

public abstract Mono updateCheckpoint(Checkpoint checkpoint)

Novedades el punto de control en el almacén de datos de una partición.

Parameters:

checkpoint - Información de punto de control que contiene el número de secuencia y el desplazamiento que se almacenarán para esta partición.

Returns:

que Mono se completa cuando se actualiza el punto de control.