2016-12-08 3 views
0

я хочу отправить данные из Кафка тему «тест» на elasticsearch индекс «твиттер» через logstash но мой confing не работают ошибка являетсяLogstash ожидать # что неправильно

причина => "Ожидалось один из #, => в строке 1, столбец 101 (байт 101) после ввод {kafka {bootstrap_servers => \ "localhost: 9092 \" themes => \ "test \"} фильтр {} output {elasticsearch}}

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

ответ

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"] 
    } 
} 
+0

спасибо :) помощник –

+0

@DominikBaranec в любое время :) – Kulasangar

Смежные вопросы