1.3.0

The new release 1.3.0 summary:

• Upgrade to Kafka version 0.8.2.1 and Elasticsearch 1.6.0
• StatsD support
• Dynamic flush interval option
• Fixes the bug with document id generation (instead now EL will generate the ids if not provided)

1.2.1

The new release 1.2.1 supports multiple Kafka message types as JSON and simple String, which will be indexed in ES using according type.

1.2.0

The new release 1.2.0 supports multiple action types as indexation of documents, deletion of documents and raw messages execution.

1.1.1

The new release 1.1.1 fixes the problem of messages not being sent to ES, when there is an infinite stream of messages.

1.1.0

The new release 1.1.0 makes use of the latest Elasticsearch version 1.4.0.

1.0.0

The Kafka River plugin allows you to read messages from Kafka and index bulked messages into elasticsearch.

• Support for bulk message indexing
• Support for concurrent execution
• Support to consume kafka messages from multiple brokers and partitions

Kafka version 0.8.1.1
Elasticsearch version 1.3.2