adobe/eventhub-akka-connector

Name: eventhub-akka-connector

Owner: Adobe Systems Incorporated

Description: null

Created: 2018-05-01 18:06:33.0

Updated: 2018-05-01 21:54:52.0

Pushed: 2018-05-01 21:54:50.0

Homepage: null

Size: 15650

Language: Java

GitHub Committers

User	Most Recent Commit	# Commits

Other Committers

User	Email	Most Recent Commit	# Commits

README

Akka Streams Consumer for Azure Event Hub

Akka streams connector for Azure Event Hub and an Akka streams Source. Can be used as a consumer.

Documentation

To create a new EventHubSource use the default constructor new EventHubSource() and to create a usable Akka streams source use Source.fromGraph(new EventHubSource()). To materialize it into a IEventProcessor it has to be materialized and run, like an Akka streams source( see the example for details).

There is an application.conf file where a specific Event Hub's keys and consumer groups can be specified.

Contributions

Contributions are welcome. A Sink still has to be written for the whole flow to be complete. Please fork the project and create for your finished feature a pull request.

Code of Conduct

This project abides by the Adobe Code of Conduct. See CODE OF CONDUCT.

Licensing

This project is licensed under the Apache V2 License. See LICENSE for more information.