Logstash RabbitMQ input with lazy queue

Elastic Stack Logstash
1

Hi,

I would like to load data from RabbitMQ with Logstash with the following pipeline:
input {
rabbitmq {
host => "xxx.xxx.xxx.xxx"
port => 5672
user => "guest"
password => "guest"
queue => "test_queue"
durable => true
}
}
filter {
}
output {
stdout {
codec => rubydebug
}

file {
codec => json
path => "/data/rabbit/test-%{+YYYY-MM-dd}.json"
}
}

I receive the following error in the logstash-plain.log:
Error while setting up connection for rabbitmq input! Will retry. {:message=>"#method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-mode' for queue 'test_queue' in vhost '/': received none but current is the value 'lazy' of type 'longstr', class-id=50, method-id=10)"

Please help me with this pipeline!
Thx

2

I was stupid!
The answer is:
arguments => {
"x-queue-mode" => "lazy"
}

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.