Fluentd plugin for kafka-0.8 plus