该文件定义了logstash从哪里获取输入，然后输出到哪里
代码语言：javascript复制#从Beats输入，以json格式输出到Elasticsearch
input {
beats {
port => 5044
codec => 'json'
}
}
output {
elasticsearch {
#elasticsearch地址，多个以','隔开
hosts => ["http://localhost:9200"]
#创建的elasticsearch索引名，可以自定义也可以使用下面的默认
index => "%{[@metadata][beat]}-%{[@metadata][version]}-%{ YYYY.MM.dd}"
}
}
#从kafka输入，以json格式输出到Elasticsearch
input {
kafka {
#kafka地址，多个用逗号','隔开
bootstrap_servers => ["ip1:port2","ip2:port2"]
#消费者组
group_id => 'test'
# kafka topic 名称
topics => 'logstash-topic'
codec => 'json'
}
}
output {
elasticsearch {
hosts => ["http://localhost:9200"]
index => "%{[@metadata][beat]}-%{[@metadata][version]}-%{ YYYY.MM.dd}"
}
}
