Currently, there is no non-blocking Flume client. You can use the standard threads-futures combination to achieve a similar effect.
Thanks, Hari On Wed, Jan 28, 2015 at 8:40 AM, Loic Descotte <[email protected]> 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 : > https://github.com/cloudera/flume/blob/master/flume-core/src/main/java/com/cloudera/flume/handlers/thrift/ThriftEventSink.java > Do you know how to achieve this? > Thanks, best regards > Loïc
