Kafka producer/consumer with 0.8.2-beta

- producer/consumer module splitted
- KafkaSink with java kafka producer without any duplicate queue
I don't recall why I implemented this when I first created it :) but I don't see any specific reason it should start from the range of retention.get().