First complete version of Kafka flowlet