Product - logstash-5.0.0-beta1
Checked in Gemfile that logstash-input-kafka plugin is available.
my logstash-pipeline.conf has below output config.
hosts => ["x.x.x.x:9200","y.y.y.y:9200"]
workers => 3
when I run bin/logstash -f logstash-pipeline.conf --config.test_and_exit , I get the following error.
[2016-10-04T13:59:45,652][FATAL][logstash.runner ] The given configuration is invalid. Reason: You are using a plugin that doesn't support workers but have set the workers value explicitly! This plugin uses the shared and doesn't need this option
As per https://www.elastic.co/guide/en/logstash/master/plugins-outputs-elasticsearch.html#plugins-outputs-elasticsearch-workers , workers is a valid setting.
Workaround : remove the workers setting from the pipeline config file.