logstash 判断是否存在 if ![metricset] {}
input {
beats {
port => 5044
}
udp {
port => "5050"
}
}
output {
if ![metricset] {
kafka {
bootstrap_servers => '39.98.51.253:9092'
topic_id => 'iotdata'
codec => json_lines
}
}
stdout { codec => rubydebug }
