Uses of Class
com.azure.messaging.eventhubs.models.Checkpoint
Package
Description
Package containing classes for creating
EventHubProducerAsyncClient
,
EventHubProducerClient
,
EventHubConsumerAsyncClient
,
EventHubConsumerClient
, or
EventProcessorClient
to perform operations on Azure Event Hubs.Package containing implementation for
CheckpointStore
that uses Storage
blobs for persisting checkpoints and partition ownership details.Package containing implementation of CheckpointStore that uses Azure Redis Cache, specifically Jedis.
Package containing classes used for creating and configuring events that are being sent-to and received-from Azure
Event Hubs service.
-
Uses of Checkpoint in com.azure.messaging.eventhubs
Modifier and TypeMethodDescriptionCheckpointStore.listCheckpoints
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Called to get the list of checkpoints from the underlying data store.Modifier and TypeMethodDescriptionCheckpointStore.updateCheckpoint
(Checkpoint checkpoint) Updates the checkpoint in the data store for a partition. -
Uses of Checkpoint in com.azure.messaging.eventhubs.checkpointstore.blob
Modifier and TypeMethodDescriptionBlobCheckpointStore.listCheckpoints
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Modifier and TypeMethodDescriptionBlobCheckpointStore.updateCheckpoint
(Checkpoint checkpoint) Updates the checkpoint in Storage Blobs for a partition. -
Uses of Checkpoint in com.azure.messaging.eventhubs.checkpointstore.jedis
Modifier and TypeMethodDescriptionJedisRedisCheckpointStore.listCheckpoints
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) This method returns the list of checkpoints from the underlying data store, and if no checkpoints are available, then it returns empty results.Modifier and TypeMethodDescriptionJedisRedisCheckpointStore.updateCheckpoint
(Checkpoint checkpoint) This method updates the checkpoint in the Jedis resource for a given partition. -
Uses of Checkpoint in com.azure.messaging.eventhubs.models
Modifier and TypeMethodDescriptionCheckpoint.setConsumerGroup
(String consumerGroup) Sets the consumer group name associated with this checkpoint.Checkpoint.setEventHubName
(String eventHubName) Sets the Event Hub name associated with this checkpoint.Checkpoint.setFullyQualifiedNamespace
(String fullyQualifiedNamespace) Sets the fully qualified namespace of the Event Hub.Sets the offset of the last successfully processed event to store as checkpoint.Checkpoint.setPartitionId
(String partitionId) Sets the partition id associated with this checkpoint.Checkpoint.setSequenceNumber
(Long sequenceNumber) Sets the sequence number of the last successfully processed event to store as checkpoint.