I'd use the one in Flume trunk (it was far better tested) and we also have Kafka-channel :) And it works with 0.8.1.
https://github.com/apache/flume/tree/trunk/flume-ng-sources/flume-kafka-source https://github.com/apache/flume/tree/trunk/flume-ng-sinks/flume-ng-kafka-sink https://github.com/apache/flume/tree/trunk/flume-ng-channels/flume-kafka-channel Gwen On Fri, Dec 12, 2014 at 5:33 PM, Jack Ye <jack...@jasper.com> wrote: > Does this work for kafka 0.8.1? thank you > > https://github.com/baniuyao/flume-kafka >
