Logstash 期望 # 出了什么问题

Question

我想通过logstash将数据从kafka主题“test”发送到elasticsearch index“twitter”，但我的配置不起作用 错误是

reason=>“预期为 #, => 之一，位于第 1 行第 101 列（字节 101）之后 输入 { kafka { bootstrap_servers=>\"localhost:9092\" 主题=>\"test\"} 过滤器{} 输出{ elasticsearch"}

input { kafka { bootstrap_servers=>"localhost:9092" topics=>"test"} filter{}  output{ elasticsearch {hosts=>["127.0.0.1:9200"]}}

Answer 1

您的input 中似乎缺少右括号：

input { 
    kafka { 
        bootstrap_servers=>"localhost:9092" 
        topics=>"test"
    }
}   <---- this bracket was missing in yours

filter{}  

output { 
    elasticsearch {
        hosts => ["127.0.0.1:9200"]
    }
}