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