inloco/kafka-elasticsearch-injector

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster