Kafka producer/consumer with 0.8.2-beta

- producer/consumer module splitted
- KafkaSink with java kafka producer without any duplicate queue
Any reason why we need to split the producer and consumer?