elasticsearch - Logstash期望#出什么问题了

标签 elasticsearch apache-kafka logstash

我想通过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/

相关文章:

linux - 将运行logstash 的脚本的conf 文件放在哪里?

elasticsearch - 如何构造这个Elasticsearch查询对象?

elasticsearch - 仅针对具有过滤器的排序查询结果聚合脚本,而不是完整数据集

elasticsearch - 如何将日志从Fortigate(VM)传输到ELK?

elasticsearch - 如何渗透 simple_query_string/query_string 查询

java - Kafka 管理消费者组之间的偏移量

elasticsearch - 解析logstash中的日期字段以进行 Elasticsearch

java - KafkaProducer 未生成> 1 MB 的消息到主题

apache-kafka - 带有 .Net 客户端的 Kafka

elasticsearch - 从logstash/elasticsearch中删除某种类型的记录