Method: Fluent::KafkaPluginUtil::SSLSettings#start

Defined in:
lib/fluent/plugin/kafka_plugin_util.rb

#start ⇒ Object 



39
40
41
42
43
44
45
46
47
48
 
# File 'lib/fluent/plugin/kafka_plugin_util.rb', line 39

def start
  super

  # This is bad point here but easy to fix for all kafka plugins
  unless log.respond_to?(:formatter)
    def log.formatter
      Fluent::KafkaPluginUtil::SSLSettings::DummyFormatter
    end
  end
end