发布时间：2015-11-03 10:36:51
编写logstash到kafka的接口，如下图所示。[root@rac01 ~]# cat kafka.conf input { stdin { add_field => {"key" => "value"} codec => "plain" tags => ["add"] type => "std"&.........【阅读全文】
发布时间：2015-10-29 17:36:48
三台操作系统搭建kafka集群环境OS版本：[root@Master kafka_2.10-0.8.2.2]# lsb_release -aLSB Version::base-4.0-amd64:base-4.0-noarch:core-4.0-amd64:core-4.0-noarch:graphics-4.0-amd64:graphics-4.0-noarch:printing-4.0-amd64:printing-4.0-noarchDistributor ID:CentOSDescription:CentOS release 6.5 (F.........【阅读全文】
发布时间：2015-10-27 18:15:08
kafka官网：http://kafka.apache.org/documentation.html#producerconfigs修改配置文件server.properties# Hostname the broker will bind to. If not set, the server will bind to all interfaceshost.name=192.168.56.120创建topic[root@ELk kafka_2.10-0.8.2.2]# bin/kafka-topics.sh --create --zookeeper loc.........【阅读全文】
发布时间：2015-10-27 15:39:17
[root@ELk logstash-1.5.4]# cat logstash-stdin.conf input { stdin{}}output { stdout{}}[root@ELk logstash-1.5.4]# bin/logstash agent -f logstash-stdin.conf Logstash startup completedHello World2015-10-27T07:37:26.435Z ELk Hello World.........【阅读全文】
发布时间：2015-10-27 14:38:51
[root@ELk bin]# ./logstash -e 'input{stdin{}}output{stdout{codec=>rubydebug}}'aaaaaaa结果：Logstash startup completed{ "message" => "aaaaaaa", "@version" => "1", "@timestamp" => "2015-10-27T06:00:04.615Z", .........【阅读全文】
