当前位置:   article > 正文

logstash+kafka+es(3)

logstash+kafka+es

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"
    }     
}
 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/从前慢现在也慢/article/detail/975806
推荐阅读
相关标签
  

闽ICP备14008679号