mesos(kafka partition -> your binary [-> other kafka topic]) - View it on GitHub