Elasticsearch kafka plugin now supports Bulk indexing of messages and concurrent multiple thread execution. The size of bulk and number of concurrent threads will be defined by the client.
Removed unused classes
Merge branch 'master' of https://github.com/mariamhakobyan/elasticsearch-river-kafka