赞
踩
input {
# 从文件读取日志信息 输送到控制台
kafka {
bootstrap_servers => "192.168.56.107:9092,192.168.56.102:9092,192.168.56.103:9092"
topics => ["goods_mylog"]
}
}
# filter {
#
# }
output {
# 标准输出
# stdout {}
# 输出进行格式化,采用Ruby库来解析日志
stdout { codec => rubydebug }
elasticsearch {
hosts => ["192.168.56.107:9200","192.168.56.102:9200","192.168.56.103:9200"]
index => "goods_mylog"
}
}
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。