This service reads the contents of a Kafka topic and ingest each message as a document into elasticsearch.