updated to kafka 0.8.1, scala 2.10.4;

Hi @baniuyao,

Please review the updated classes after upgrading to 0.8.1. Thanks.