Kafka producer/consumer with 0.8.2-beta

- producer/consumer module splitted
- KafkaSink with java kafka producer without any duplicate queue
Consider move this to a separate method and document it to improve readability.