Package | Description |
---|---|
com.azure.messaging.eventhubs |
Package containing classes for creating
EventHubProducerAsyncClient ,
EventHubProducerClient ,
EventHubConsumerAsyncClient ,
EventHubConsumerClient , or
EventProcessorClient to perform operations on Azure Event Hubs. |
com.azure.messaging.eventhubs.models |
Package containing classes used for creating and configuring events that are being sent-to and received-from Azure
Event Hubs service.
|
Modifier and Type | Method and Description |
---|---|
Mono<Void> |
CheckpointStore.updateCheckpoint(Checkpoint checkpoint)
Updates the checkpoint in the data store for a partition.
|
Modifier and Type | Method and Description |
---|---|
Checkpoint |
Checkpoint.setConsumerGroup(String consumerGroup)
Sets the consumer group name associated with this checkpoint.
|
Checkpoint |
Checkpoint.setEventHubName(String eventHubName)
Sets the Event Hub name associated with this checkpoint.
|
Checkpoint |
Checkpoint.setFullyQualifiedNamespace(String fullyQualifiedNamespace)
Sets the fully qualified namespace of the Event Hub.
|
Checkpoint |
Checkpoint.setOffset(Long offset)
Sets the offset of the last successfully processed event to store as checkpoint.
|
Checkpoint |
Checkpoint.setPartitionId(String partitionId)
Sets the partition id associated with this checkpoint.
|
Checkpoint |
Checkpoint.setSequenceNumber(Long sequenceNumber)
Sets the sequence number of the last successfully processed event to store as checkpoint.
|
Copyright © 2019 Microsoft Corporation. All rights reserved.