Ed, Did you take a look at the javadoc in the source? Basically the source uses netty as a server and the sink is just an rpc client. If you read over the doc which is in the two links below and take a look at the developer guide and still have questions just ask away and someone will help to answer.
https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java https://github.com/apache/flume/blob/trunk/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java https://flume.apache.org/FlumeDeveloperGuide.html#transaction-interface -Jeff On Tue, Sep 2, 2014 at 6:36 PM, Ed Judge <ejud...@gmail.com> wrote: > Does anyone know of any good documentation that talks about the > protocol/negotiation used between an Avro source and sink? > > Thanks, > Ed > >
