Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 5 additions & 20 deletions docs/index.asciidoc
Original file line number Diff line number Diff line change
Expand Up @@ -20,26 +20,11 @@ include::{include_path}/plugin_header.asciidoc[]

==== Description

This input will read events from a Kafka topic. It uses the 0.10 version of
the consumer API provided by Kafka to read messages from the broker.

Here's a compatibility matrix that shows the Kafka client versions that are compatible with each combination
of Logstash and the Kafka input plugin:

[options="header"]
|==========================================================
|Kafka Client Version |Logstash Version |Plugin Version |Why?
|0.8 |2.0.0 - 2.x.x |<3.0.0 |Legacy, 0.8 is still popular
|0.9 |2.0.0 - 2.3.x | 3.x.x |Works with the old Ruby Event API (`event['product']['price'] = 10`)
|0.9 |2.4.x - 5.x.x | 4.x.x |Works with the new getter/setter APIs (`event.set('[product][price]', 10)`)
|0.10.0.x |2.4.x - 5.x.x | 5.x.x |Not compatible with the <= 0.9 broker
|0.10.1.x |2.4.x - 5.x.x | 6.x.x |
|0.11.0.0 |2.4.x - 5.x.x | 6.x.x |Not compatible with the <= 0.9 broker
|==========================================================

NOTE: We recommended that you use matching Kafka client and broker versions. During upgrades, you should
upgrade brokers before clients because brokers target backwards compatibility. For example, the 0.9 broker
is compatible with both the 0.8 consumer and 0.9 consumer APIs, but not the other way around.
This input will read events from a Kafka topic.

This plugin uses Kafka Client 1.0.0. For broker compatibility, see the official https://cwiki.apache.org/confluence/display/KAFKA/Compatibility+Matrix[Kafka compatibility reference].

If you're using a plugin version that was released after {version}, see the https://www.elastic.co/guide/en/logstash/master/plugins-inputs-kafka.html[latest plugin documentation] for updated information about Kafka compatibility.

This input supports connecting to Kafka over:

Expand Down