@type kafka2 brokers "#{ENV['KAFKA_BROKERS']}" topic "#{ENV['KAFKA_TOPIC']}" @type "#{ENV['KAFKA_FORMAT_TYPE'] || 'json'}" # for more config options # see https://github.com/fluent/fluent-plugin-kafka