giraffi / fluent-plugin-amqp

Use AMQP broker to send or receive messages via FluentD
MIT License
15 stars 31 forks source link

Prefetch / Batch messages off brokers for Source #50

Open warmfusion opened 7 years ago

warmfusion commented 7 years ago

Provide user configurable (default 1) message pre-fetch sizes so that events can be consumed from brokers in larger chunks at the cost of increased memory and latency.

Required;