Использование стека ELK '7.3.2'.Использование 'kafka_2.12-2.1.1'
Как мне визуализировать мой JSON в Kibana, показывая, скажем, Up / Down для конкретного брокера.
Вот мой Logstash.config
# Beats -> Logstash -> Elasticsearch pipeline.
input {
kafka {
bootstrap_servers => "nydvalkafvm01.tradeware.com:9092"
topics => ["boris-topic"]
codec => json
}
}
filter{
json {
source => "message"
}
}
output {
elasticsearch {
action =>"index"
hosts => ["http://nyuatalcasvm01:9200"]
index => "boris-topic"
workers => 1
codec => json
#user => "elastic"
#password => "changeme"
}
}