This example uses Akka Streams in conjunction with EventHub library offered by azure-sdk-for-java.
Azure SDK for java offers asynchronous sets of APIs for their Azure services that are built upon Project Reactor's Reactive Core.
This means that we have a set of fully compliant reactive streams set of APIs that are fully compatible with Akka Stream.