Kafka producer/consumer with 0.8.2-beta

- producer/consumer module splitted
- KafkaSink with java kafka producer without any duplicate queue