com.microsoft.azure:spark-streaming-eventhubs_examples_2.11

Azure Eventhubs Connector for Spark Streaming Applications

License

License

GroupId

GroupId

com.microsoft.azure
ArtifactId

ArtifactId

spark-streaming-eventhubs_examples_2.11
Last Version

Last Version

2.1.4
Release Date

Release Date

Type

Type

jar
Description

Description

Azure Eventhubs Connector for Spark Streaming Applications

Download spark-streaming-eventhubs_examples_2.11

How to add to project

<!-- https://jarcasting.com/artifacts/com.microsoft.azure/spark-streaming-eventhubs_examples_2.11/ -->
<dependency>
    <groupId>com.microsoft.azure</groupId>
    <artifactId>spark-streaming-eventhubs_examples_2.11</artifactId>
    <version>2.1.4</version>
</dependency>
// https://jarcasting.com/artifacts/com.microsoft.azure/spark-streaming-eventhubs_examples_2.11/
implementation 'com.microsoft.azure:spark-streaming-eventhubs_examples_2.11:2.1.4'
// https://jarcasting.com/artifacts/com.microsoft.azure/spark-streaming-eventhubs_examples_2.11/
implementation ("com.microsoft.azure:spark-streaming-eventhubs_examples_2.11:2.1.4")
'com.microsoft.azure:spark-streaming-eventhubs_examples_2.11:jar:2.1.4'
<dependency org="com.microsoft.azure" name="spark-streaming-eventhubs_examples_2.11" rev="2.1.4">
  <artifact name="spark-streaming-eventhubs_examples_2.11" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.microsoft.azure', module='spark-streaming-eventhubs_examples_2.11', version='2.1.4')
)
libraryDependencies += "com.microsoft.azure" % "spark-streaming-eventhubs_examples_2.11" % "2.1.4"
[com.microsoft.azure/spark-streaming-eventhubs_examples_2.11 "2.1.4"]

Dependencies

compile (4)

Group / Artifact Type Version
org.apache.spark : spark-sql_2.11 jar 2.1.0
org.scala-lang.modules : scala-xml_2.11 jar 1.0.6
com.microsoft.azure : azure-eventhubs jar 0.14.3
org.scalaj : scalaj-http_2.11 jar 2.3.0

provided (1)

Group / Artifact Type Version
org.apache.spark : spark-streaming_2.11 jar 2.1.0

test (10)

Group / Artifact Type Version
org.apache.spark : spark-core_2.11 test-jar 2.1.0
org.apache.spark : spark-sql_2.11 test-jar 2.1.0
org.apache.spark : spark-streaming_2.11 test-jar 2.1.0
org.scalacheck : scalacheck_2.11 jar 1.11.3
junit : junit jar 4.12
org.mockito : mockito-core jar 1.10.8
org.powermock : powermock-module-junit4 Optional jar 1.6.1
org.powermock : powermock-api-mockito Optional jar 1.6.1
org.scalatest : scalatest_2.11 jar 2.2.6
com.novocode : junit-interface jar 0.10

Project Modules

There are no modules declared in this project.

Azure Event Hubs + Apache Spark Connector

Azure Event Hubs Connector for Apache Spark

chat on gitter build status star our repo

This is the source code of the Azure Event Hubs Connector for Apache Spark.

Azure Event Hubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them into multiple applications. Spark Streaming and Structured Streaming are scalable and fault-tolerant stream processing engines that allow users to process huge amounts of data using complex algorithms expressed with high-level functions like map, reduce, join, and window. This data can then be pushed to filesystems, databases, or even back to Event Hubs.

By making Event Hubs and Spark easier to use together, we hope this connector makes building scalable, fault-tolerant applications easier for our users.

Latest Releases

Spark

Spark Version Package Name Package Version
Spark 3.0 azure-eventhubs-spark_2.12 Maven Central
Spark 2.4 azure-eventhubs-spark_2.11 Maven Central
Spark 2.4 azure-eventhubs-spark_2.12 Maven Central
Spark 2.3 azure-eventhubs-spark_2.11 Maven Central
Spark 2.2 azure-eventhubs-spark_2.11 Maven Central
Spark 2.1 azure-eventhubs-spark_2.11 Maven Central

Databricks

Databricks Runtime Version Artifact Id Package Version
Databricks Runtime 7.X azure-eventhubs-spark_2.12 Maven Central
Databricks Runtime 6.X azure-eventhubs-spark_2.11 Maven Central
Databricks Runtime 6.X azure-eventhubs-spark_2.12 Maven Central
Databricks Runtime 5.X azure-eventhubs-spark_2.11 Maven Central
Databricks Runtime 5.X azure-eventhubs-spark_2.12 Maven Central
Databricks Runtime 4.X azure-eventhubs-spark_2.11 Maven Central
Databricks Runtime 3.5 azure-eventhubs-spark_2.11 Maven Central

Roadmap

There is an open issue for each planned feature/enhancement.

Usage

Linking

For Scala/Java applications using SBT/Maven project definitions, link your application with the artifact below. Note: See Latest Releases to find the correct artifact for your version of Apache Spark (or Databricks)!

groupId = com.microsoft.azure
artifactId = azure-eventhubs-spark_2.11
version = 2.3.18

or

groupId = com.microsoft.azure
artifactId = azure-eventhubs-spark_2.12
version = 2.3.18

Documentation

Documentation for our connector can be found here. The integration guides there contain all the information you need to use this library.

If you're new to Apache Spark and/or Event Hubs, then we highly recommend reading their documentation first. You can read Event Hubs documentation here, documentation for Spark Streaming here, and, the last but not least, Structured Streaming here.

FAQ

We maintain an FAQ - reach out to us via gitter if you think anything needs to be added or clarified!

Further Assistance

If you need additional assistance, please don't hesitate to ask! General questions and discussion should happen on our gitter chat. Please open an issue for bug reports and feature requests! Feedback, feature requests, bug reports, etc are all welcomed!

Contributing

If you'd like to help contribute (we'd love to have your help!), then go to our Contributor's Guide for more information.

Build Prerequisites

In order to use the connector, you need to have:

More details on building from source and running tests can be found in our Contributor's Guide.

Build Command

// Builds jar and runs all tests
mvn clean package

// Builds jar, runs all tests, and installs jar to your local maven repository
mvn clean install
com.microsoft.azure

HDInsight

Versions

Version
2.1.4
2.1.3
2.1.2
2.1.1
2.1.0
2.0.9
2.0.8
2.0.7
2.0.6
2.0.5
2.0.4
2.0.3