发布时间:2015-10-26 15:10:41
1.环境说明[root@Master hadoop-2.6.0]#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 (Final)Release:6.5Codename:Final.........【阅读全文】
发布时间: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.........【阅读全文】