Merged to ddth-kafka and closed