我想通过logstash将数据从kafka主题“test”发送到elasticsearch索引“twitter”,但是我的通话无法正常工作
错误是
reason=>"Expected one of #, => at line 1, column 101 (byte 101) after input { kafka { bootstrap_servers=>\"localhost:9092\" topics=>\"test\"} filter{} output{ elasticsearch "}
input { kafka { bootstrap_servers=>"localhost:9092" topics=>"test"} filter{} output{ elasticsearch {hosts=>["127.0.0.1:9200"]}}
最佳答案
好像您在input
中缺少了右括号:
input {
kafka {
bootstrap_servers=>"localhost:9092"
topics=>"test"
}
} <---- this bracket was missing in yours
filter{}
output {
elasticsearch {
hosts => ["127.0.0.1:9200"]
}
}
关于elasticsearch - Logstash期望#出什么问题了,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41037389/