Currently, there is no non-blocking Flume client. You can use the standard threads-futures combination to achieve a similar effect.


On Wed, Jan 28, 2015 at 8:40 AM, Loic Descotte <> wrote:

Hi all,

I'm using Flume and I'd like to send messages in an asynchronous way,
without consuming (or blocking) too many threads.
Is there a way to call Flume in a non blocking IO way, with Thrift or
with Avro client?

Looking at this class (on the old Cloudera repository) it seems
possible, but the "nonBlocking" flag is set to false by default :

Do you know how to achieve this?

Thanks, best regards