ELK实战-logstash安装使用

操作系统：

[root@server2 ~]# wget https://artifacts.elastic.co/downloads/logstash/logstash-6.3.2.tar.gz

[root@server2 ~]# tar zxf logstash-6.3.2.tar.gz -C /usr/local/

[root@server2 ~]# cd /usr/local/logstash-6.3.2/

[root@server2 logstash-6.3.2]# bin/logstash -e 'input{stdin{}} output{stdout{codec=>rubydebug}}'

#-e代表执行的意思

input即输入的意思，input里面即使输入的方式，这里选择了stdin，就是标准输入(从终端输入)

output即输出的意思，output里面时输出的方式，这里选择了stdout，就是标准输出(输出到终端).

这里codec就是个插件，表明格式。这里放在stdout中，表示输出的格式，rubydebug时专门用来做测试的格式，一般用来在终端输出JSON格式。

[root@server2 logstash-6.3.2]# vim config/kafka_os_into_es.conf

input {

kafka {

bootstrap_servers =>

"192.168.10.129:9092"

topics => ["osmessages"]

codec => "json"

}

output {

elasticsearch {

hosts => ["192.168.10.126:9200","192.168.10.127:9200"]

index => "osmessageslog-%{+YYYY-MM-dd}"

}

[root@server2 logstash-6.3.2]# nohup bin/logstash -f config/kafka_os_into_es.conf &

[root@kafkazk1 bin]# ./kafka-topics.sh --zookeeper 192.168.10.129:2181 --list