Alpakka project (https://doc.akka.io/docs/alpakka/current/index.html) is a reactive enterprise integration library for Java and Scala, based on Reactive Streams and Akka (https://akka.io/).
Reactive streams are based on components—the most important ones are Source (that are used to read data from different sources) and Sink (that are used to write data in storages).
Alpakka supports Source and Sink for many data stores and Elasticsearch is one of them.
In this recipe, we will go through a common scenario—read a CSV file and ingest it in Elasticsearch.