I’m testing around Telegraf with an amqp_consumer input and a InfluxDB (single node) output (using Docker on OS X).
Everything was working fine except when I tested some failure scenarios.
If InfluxDB server stops, Telegraf cannot write the data and therefore the buffer is not cleared. But the messages are still ACKed on the RabbitMQ side. So if Telegraf would go down, messages already delivered would be lost.
Is there anyway to tell Telegraf input plugin amqp_consumer to ACK messages only when data is written ?
There is a max_undelivered_messages property (plugin README) but it seems buggy atm :
E! Error parsing /etc/telegraf/telegraf.conf, line 10: field corresponding to ‘max_undelivered_messages’ is not defined in ‘*amqp_consumer.AMQPConsumer’