Logstash 5.1.1 release page has a section on kafka enhancements that says
If you need 0.10.1.0 support, you can install the latest version on 5.1 by using
bin/logstash update logstash-input-kafka
bin/logstash update logstash-output-kafka
The command is wrong and I've filed an issue.
Even when the command is corrected, when I run it, it doesn't upgrade:
./bin/logstash-plugin update logstash-input-kafka
Updating logstash-input-kafka
No plugin updated
./bin/logstash-plugin update logstash-output-kafka
Updating logstash-output-kafka
No plugin updated
The logstash log file still has this line which makes me think it isn't upgraded:
[2016-12-13T16:51:56,317][INFO ][org.apache.kafka.common.utils.AppInfoParser] Kafka version : 0.10.0.1
[2016-12-13T16:51:56,317][INFO ][org.apache.kafka.common.utils.AppInfoParser] Kafka commitId : a7a17cdec9eaa6c5
The log says Kafka version is 0.10.0.1 but I'm using the Kafka server 0.10.1.0. My kakfa binary is /usr/local/kafka/kafka_2.10-0.10.1.0/
Can someone clarify?