ELK Kafka json to elk

Posted MOSS

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ELK Kafka json to elk相关的知识,希望对你有一定的参考价值。

Logstash配置

   

input {

kafka {

zk_connect => "127.0.0.1:2181"

topic_id => "cluster"

codec => plain

reset_beginning => false

consumer_threads => 5

decorate_events => true

}

}

   

   

output {

if [type]=="cluster3" or [type]=="cluster2" or [type]=="clusterjson"

{

elasticsearch {

hosts => ["localhost:9200"]

index => "test-kafka-%{type}-%{+YYYY-MM}"

}

}

   

stdout { codec => rubydebug }

}

   

Server.properties 主要内容

broker.id=0

   

############################# Socket Server Settings #############################

   

listeners=PLAINTEXT://:9092

   

# The port the socket server listens on

port=9092

   

   

Server-1.properties 主要内容

   

broker.id=1

   

############################# Socket Server Settings #############################

   

listeners=PLAINTEXT://:9093

   

# The port the socket server listens on

port=9093

   

   

启动kafka,server.properties和server-1.properties

E:\\soft\\elk\\kafka_2.11-0.9.0.1>bin\\windows\\kafka-server-start.bat config\\custom\\server-1.properties

   

创建topic,并查看状态

   

   

查找端口占用情况,并删除一个节点

   

   

查看 topic状态

   

   

   

生产者输入json数据,如下

   

{"Name":"BULK 7","Data":7,"CreateTime":"2016-04-05T10:16:22Z","type":"cluster3"}

   

Kibana 4显示如下

   

   

   

   

   

   

   

以上是关于ELK Kafka json to elk的主要内容,如果未能解决你的问题,请参考以下文章

ELK采集MySQL慢日志实现

ELK采集MySQL慢日志实现

ELK搭建实时日志分析平台(elk+kafka+metricbeat)-KAFKA搭建

MySQL-To-JSON 的 Kafka 生产者 Maxwell | 软件推介

ELK+Kafka集群

ELK+Kafka 企业日志收集平台