fluent-plugin-rabbitmq
fluent-plugin-rabbitmq copied to clipboard
Fluent input/output plugin for RabbitMQ.
Hello, receiving messages with the next format in the record: {"time": "2023-05-07T13:11:30", "payload": "[values]"} gives problems in terms of the time, which doesn't appear in the record (delivery_info) If I...
Hello, I receive error when using source plugin with [record_transformer](https://docs.fluentd.org/filter/record_transformer) filter. Here is fluentd config: ```xml @type rabbitmq tag test host "#{ENV['RABBITMQ_HOST'] || 'rabbitmq'}" user "#{ENV['RABBITMQ_USER'] || 'user'}" pass "#{ENV['RABBITMQ_PASSWORD']...
Hi, I'm setting up AMQP/TLS on my rabbitmq server but trying to connect fluentd to rabbitmq using TLS is not working. ``` fluentd-rabbit-vdev_1 | 2019-10-03 12:16:01 +0000 [info]: adding source...
When using this plugin from within Docker it seems that the queue isn't automatically created when the service first runs. If I manually create the queue and then start Fluentd...