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