Logsta sh не транслируется на кафку - PullRequest
Новая
       12

Logsta sh не транслируется на кафку

2 голосов
/ 06 апреля 2020

я сохранил очень простой c файл conf, который читает журналы из папки и отправляет их в kafka следующим образом: 

input {
file
 {
        add_field => { "app_id" => "12345"}
        path => "/tmp/logs/*.log"
        start_position => "beginning"
 }
}
output {
 if [app_id] == "12345" {
        kafka {
                topic_id => "mytopic"
                bootstrap_servers => "kafka_topic_id:9043"
                ssl => false
                }
        }
}

Мои журналы sh журналы показывают "конвейер запущен" , Однако я не вижу ничего на кибане. Это означает, что поток либо не передается в kafka, либо из kafka в elasti c данные поиска не передаются. Я что-то пропустил в конф?

...