Logstash-input-rabbitmq 配置

 

在windows下，新建一个 config_rabbitmq.conf 配置文件

开始logstash的时候，新建一个 run_rabbitMQ.bat 批处理，内容是 logstash -f config_rabbitMQ.conf 

运行 run_rabbitMQ.bat 批处理文件就行了

 

 

先在rabbitmq创建一个队列，使用默认设置

 

配置 .conf 文件

input {
    rabbitmq{
        host => "127.0.0.1"
        user => "admin"
        password => "admin"
        queue => "test.logstash.v1"　　#队列名称
        durable => true　　#和队列保持一致
        codec => "plain"
    }
}

output {
    stdout{
        codec=>json
    }
}

 

 

官方配置说明：https://www.elastic.co/guide/en/logstash/7.1/plugins-inputs-rabbitmq.html