Update kafka from 0.7.0 to 0.8.1