Uses of Class
com.azure.messaging.eventhubs.models.Checkpoint
Packages that use 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
Methods in com.azure.messaging.eventhubs that return types with arguments of type CheckpointModifier and TypeMethodDescriptionCheckpointStore.listCheckpoints
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Called to get the list of checkpoints from the underlying data store.Methods in com.azure.messaging.eventhubs with parameters of type CheckpointModifier 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
Methods in com.azure.messaging.eventhubs.checkpointstore.blob that return types with arguments of type CheckpointModifier and TypeMethodDescriptionBlobCheckpointStore.listCheckpoints
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Methods in com.azure.messaging.eventhubs.checkpointstore.blob with parameters of type CheckpointModifier and TypeMethodDescriptionBlobCheckpointStore.updateCheckpoint
(Checkpoint checkpoint) Updates the checkpoint in Storage Blobs for a partition. -
Uses of Checkpoint in com.azure.messaging.eventhubs.checkpointstore.jedis
Methods in com.azure.messaging.eventhubs.checkpointstore.jedis that return types with arguments of type CheckpointModifier 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.Methods in com.azure.messaging.eventhubs.checkpointstore.jedis with parameters of type CheckpointModifier 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
Methods in com.azure.messaging.eventhubs.models that return CheckpointModifier 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.