Kafka sink for flume-ng