Как выводить логи в разные темы Кафки под разными ключевыми словами? - PullRequest
Новая
       67

Как выводить логи в разные темы Кафки под разными ключевыми словами?

1 голос
/ 18 октября 2019

Вот мой входной файл журнала Logstash: 

{"timestamp":"2019-10-18T16:37:53.137068+0800","flow_id":1072393101531249,"in_iface":"eno1","event_type":"event A"}
{"timestamp":"2019-10-18T16:37:53.137069+0800","flow_id":1072393101531249,"in_iface":"eno1","event_type":"event B"}

Теперь я хочу вывести эти журналы на разные темы кафки (topic.A и topic.B), основанные на разных event_type. Вот моя текущая конфигурация Logstash: 

input {
  file {
    path => "/data/*.json"
  }
}
filter {

}
output {
  kafka {
    codec => plain {
      format => "%{message}"
    }
    topic_id => "topic.A"
    ...
  }
}

Как я могу делать то, что я хочу в фильтре logstash и выводить?

...