baniuyao/flume-ng-kafka-sink — pull request #3 by alanma (2014-04-19 15:52:27+00:00)
Title: updated to kafka 0.8.1, scala 2.10.4;

Hi @baniuyao,

I've updated the sink implementation with the following changes. COuld you please review and merge if acceptable?

1. updated to kafka 0.8.1, scala 2.10.4;
2. replaced deprecated producerData usage in the sink class;
3. fixed tests after the upgrades