本文共 1522 字,大约阅读时间需要 5 分钟。
安装Logstash是一个相对简单但需仔细完成的过程。以下将详细介绍环境配置和操作步骤,帮助您顺利完成Logstash的安装和部署。
安装Logstash前,请确保您的环境符合以下要求:
安装JDK后,确保系统路径已添加JDK的bin目录,这样可以方便地运行Logstash命令。
下载指定版本的Logstash并解压
首先,访问Logstash的官方网站,根据您的需求选择适当版本进行下载。下载完成后,解压压缩包,通常会将解压后的目录命名为logstash-版本号
。
运行测试
在终端中进入Logstash的bin目录,执行以下命令启动Logstash进程:
cd logstash-2.1.1/bin./logstash -e 'input{stdin{}}output{stdout{codec=>rubydebug}}'
输入任意文本内容(例如Hello World
),Logstash会返回相应的处理结果。
简单场景 - 监控日志文件并输出至Kafka
创建配置文件:新建一个名为stdout_kafka.conf
的文件,内容如下:
input { file { path => ["/var/log/diagonAlley/diagonAlley.log"] type => "log4j" start_position => "beginning" }}output { kafka { bootstrap_servers => "192.168.1.181:9092,192.168.1.181:9093,192.168.1.181:9094" topic_id => "logstash" compression_type => "gzip" }}
将该配置文件放入Logstash的bin目录中。
在终端中执行以下命令:
./logstash -f stdout_kafka.conf
简单场景 - 监控Kafka消息并输出至Elasticsearch
创建配置文件:新建一个名为stdout_elasticsearch.conf
的文件,内容如下:
input { kafka { zk_connect => "192.168.1.181:2181" topic_id => "logstash" }}output { elasticsearch { hosts => ["192.168.1.181:9100"] index => "logstash-%{type}-%{+YYYY.MM.dd}" workers => 5 }}
将该配置文件放入Logstash的bin目录中。
在终端中执行以下命令:
./logstash -f stdout_elasticsearch.conf
通过以上步骤,您可以轻松完成Logstash的安装和配置。如果遇到任何问题,请参考官方文档或社区获取帮助。
转载地址:http://wjufk.baihongyu.com/