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

Reply via email to