Kafka plugin for Logstash not working

Elastic Stack Logstash
1

I am getting theses errors

  1. my Kafka version 2.12-1
  2. Logstash version 6.3
  3. Kafka input plugin version. 8.1.1
  4. Kafka output plugin 7.1.1

my requirement read from Kafka. and write to Elasticsearch.

Can somebody give correct config?

input {
kafka {
broker_list => "localhost:2181"
topic_id => "welcometoKafka"
}

}
output{
stdout{
codec => rubydebug
}
elasticsearch{
index => "elasticlog-demo"
hosts => ["localhost:9200"]
}

stdout { codec => json {} }

[ERROR][logstash.inputs.kafka ] Unknown setting 'broker_list' for kafka
[2018-07-11T11:23:28,978][ERROR][logstash.inputs.kafka ] Unknown setting 'topic_id' for kafka
[2018-07-11T11:23:29,000][ERROR][logstash.agent ] Failed to execute action

2

See the plugin documentation for a list of valid options. You're probably looking for the bootstrap_servers and topics options.

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.