clone of https://github.com/baniuyao/flume-ng-kafka-sink but updated