Application must be able to consume Kafka topics and load the data as bulk into an Elasticsearch index