Flume to Kafka Sink fork from Marcelo Valle (Redoop)