File tree Expand file tree Collapse file tree 3 files changed +3
-2
lines changed
sdk/eventhubs/azure-messaging-eventhubs
src/main/java/com/azure/messaging/eventhubs Expand file tree Collapse file tree 3 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -342,6 +342,7 @@ EventProcessorClient eventProcessorClient = new EventProcessorClientBuilder()
342342 .processEvent(eventContext - > {
343343 System . out. println(" Partition id = " + eventContext. getPartitionContext(). getPartitionId() + " and "
344344 + " sequence number of event = " + eventContext. getEventData(). getSequenceNumber());
345+ eventContext. updateCheckpoint(); // Update checkpoint for this partition.
345346 })
346347 .processError(errorContext - > {
347348 System . out
Original file line number Diff line number Diff line change @@ -115,7 +115,7 @@ EventHubProducerAsyncClient createProducer() {
115115 * @param consumerGroup The name of the consumer group this consumer is associated with. Events are read in the
116116 * context of this group. The name of the consumer group that is created by default is
117117 * {@link EventHubClientBuilder#DEFAULT_CONSUMER_GROUP_NAME "$Default"}.
118- * @param prefetchCount The set of options to apply when creating the consumer .
118+ * @param prefetchCount The number of events to queue locally .
119119 * @return An new {@link EventHubConsumerAsyncClient} that receives events from the Event Hub.
120120 * @throws NullPointerException If {@code consumerGroup} is {@code null}.
121121 * @throws IllegalArgumentException If {@code consumerGroup} is an empty string.
Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ EventHubProducerClient createProducer() {
7979 * @param consumerGroup The name of the consumer group this consumer is associated with. Events are read in the
8080 * context of this group. The name of the consumer group that is created by default is {@link
8181 * EventHubClientBuilder#DEFAULT_CONSUMER_GROUP_NAME "$Default"}.
82- * @param prefetchCount The set of options to apply when creating the consumer .
82+ * @param prefetchCount The number of events to queue locally .
8383 * @return An new {@link EventHubConsumerClient} that receives events.
8484 * @throws NullPointerException If {@code consumerGroup} is null.
8585 * @throws IllegalArgumentException If {@code consumerGroup} is an empty string.
You can’t perform that action at this time.
0 commit comments