logstash+kafka+es（3）

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