Auto acknowledgement to message from RabbitMQ

Elastic Stack Logstash
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

2

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

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

4

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

5

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

6

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