3.4 KiB
3.4 KiB
Azure Event Hubs Java samples
Note:: The samples present here enables Java developers to easily ingest and process events from an instance of Azure Event Hubs using the legacy libraries com.microsoft.azure:azure-eventhubs and com.microsoft.azure:azure-eventhubs-eph. We strongly recommend you to use the current library com.azure:azure-messaging-eventhubs instead.
- Java samples for current Azure Event Hubs client library
- Java samples for current Azure Event Hubs Checkpoint Store client library
Prerequisites
- The samples depend on the Java JDK 1.8 and are built using Maven. You can download Maven. Install and configure Maven. The sample require Maven version > 3.3.9.
- You need an Azure Subscription, if you do not have one - create a free account before you begin
- An Event Hubs namespace and an event hub where you ingest the data
- A SAS key to access the event hub
Sending events
- SendBatch - The SendBatch sample illustrates how to ingest batches of events into your event hub.
- SimpleSend - The SimpleSend sample illustrates how to ingest events into your event hub.
- AdvanceSendOptions - The AdvancedSendOptions sample illustrates the various options available with Event Hubs to ingest events.
Processing events
- ReceiveByDateTime - The ReceiveByDateTime sample illustrates how to receive events from an event hub partition using a specific date-time offset.
- ReceiveUsingOffset - The ReceiveUsingOffset sample illustrates how to receive events from an event hub partition using a specific data offset.
- ReceiveUsingSequenceNumber - The ReceiveUsingSequenceNumber sample illustrates how can receive from an event hub partitions using a sequence number.
- EventProcessorSample - The EventProcessorSample sample illustrates how to receive events from an event hub using the event processor host, which provides automatic partition selection and fail-over across multiple concurrent receivers.
Benchmarks
- AutoScaleOnIngress - The AutoScaleOnIngress sample illustrates how an event hub can automatically scale up on high loads. The sample will send events at a rate that just exceed the configured rate of an event hub, causing the event hub to scale up.
- IngressBenchmark - The IngressBenchmark sample allows measuring the ingress rate.
Build and run
All samples can be built at once with
mvn clean package
The samples are dropped into the respective sample's ./target subfolder. The build packages all dependencies into a single assembly so that you can execute them with:
java -jar ./target/{project}-1.0.0-jar-with-dependencies.jar