A kafka source & sink for flume