Auto acknowledgement to message from RabbitMQ


(Makara) #1

Hi
List-users
I have a logstash consumer which is reading messages from RabbitMQ queues through rabbitmq input. I want to speed up the delivery using auto acknowledgement = true . I have checked the logstash documentation for auto acknowledgement features. But there is nothing such auto ack attribute here.

How can i accomplish this features through logstash.

input {
rabbitmq {
host => "localhost"
queue => "MessageQueue"
durable => true
key => "MessageKey"
exchange => "MessageExchange"
exchange_type => "topic"
port =>"5672"
password => "rabbit"
auto_delete => false
}
}

Thanks


(Magnus Bäck) #2

Not sure exactly what you mean. What happens when you set ack => false in your rabbitmq input?


(Makara) #3

Hi
Magnusbaeck
Thanks for quick reply. I have not set ack = > false as i think , it will make consumer to send no ack at all to RMQ.

Acknowledgement is basically a notification for RabbitMQ broker that a particular message has been processed and the broker doesn't need to worry about it anymore. In particular it shouldn't redeliver to message to this or some other consumer.

I am trying to achieve the above through logstash

Thanks


(Magnus Bäck) #4

The ack option selects whether explicit acks will be sent or if auto-acks will be used.


(Makara) #5

Awesome, i.e ack => false in the logstash configuration will make sure auto ack to true.


(system) #6

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