This is the source code of EventHubsReceiver for Spark Streaming.
Here is an example project that uses EventHubsReceiver to count messages from Azure EventHubs.
In order to build and run the examples, you need to have:
- Java 1.7/1.8 SDK.
- Maven 3.x
- Scala 2.10
mvn clean install
This command builds and installs EventHubsReceiver jar to local maven cache. Subsequently you can build any Spark Streaming application that references this jar.