first attempt at a Kafka dstream that allows for exactly-once semantics