configure

in lib/fluent/plugin/kinesis_helper/kpl.rb [17:28]


      def configure(conf)
        
        if conf.elements.none?{|e|e.name == "kinesis_producer"}
          conf.add_element("kinesis_producer")
        end
        super(conf)
        if @region.nil?
          keys = %w(AWS_REGION AMAZON_REGION AWS_DEFAULT_REGION)
          @region = ENV.values_at(*keys).compact.first
        end
      end