logstash kafka入力が機能しない

Question

私はカフカからデータを取得し、それをElasticSearchにプッシュしようとしています。ここで

は、私が使用していますlogstash構成です：

input { 
kafka { 
zk_connect => "localhost:2181" 
topic_id => "beats" 
} 
} 
output { 
elasticsearch { 
hosts => ["localhost:9200"] 
index => "elasticse" 
} 
} 

誰でもlogstash構成とここに助けることができますか？これを実行すると無効な設定エラーが発生します。

D:\logstash-5.0.0\bin>logstash -f log-uf.conf 
Sending Logstash logs to D:\logstash-5.0.0\logs\logstash-plain.txt which is now 
configured via log4j2.properties. 
[2016-11-11T16:31:32,429][ERROR][logstash.inputs.kafka ] Unknown setting 'zk_ 
connect' for kafka 
[2016-11-11T16:31:32,438][ERROR][logstash.inputs.kafka ] Unknown setting 'top 
ic_id' for kafka 
[2016-11-11T16:31:32,452][ERROR][logstash.agent   ] fetched an invalid c 
onfig {:config=>"input {\n kafka {\n zk_connect => \"localhost:2181\"\n to 
pic_id => \"beats\"\n consumer_threads => 16\n }\n}\noutput {\nelasticsearch 
{\nhosts => [\"localhost:9200\"]\nindex => \"elasticse\"\n}\n}\n", :reason=>"Som 
ething is wrong with your configuration."} 

誰でも助けてもらえますか？

Answer 1

Logstash 5は、Logstash 2.4用の設定で実行しています。

zk_connect（飼育係のホスト）が5.0

にtopicsによってbootstrap_servers（カフカブローカー）によって置き換えられ、topic_idた代わりに、この設定をお試しください：

input { 
    kafka { 
    bootstrap_servers => "localhost:9092" 
    topics => ["beats"] 
    } 
} 
output { 
    elasticsearch { 
    hosts => ["localhost:9200"] 
    index => "elasticse" 
    } 
}