flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Loic Descotte <loic.desco...@gmail.com>
Subject Non blocking IO using Flume client
Date Wed, 28 Jan 2015 16:39:41 GMT
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


Mime
View raw message