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