Initial commit for the branch, change to use kafka 0.8.1.1 with scala 2.9.2