Module: Fluent::KafkaPluginUtil::SSLSettings
- Included in:
- Fluent::Kafka2Output, Fluent::KafkaGroupInput, Fluent::KafkaInput, Fluent::KafkaOutput, Fluent::KafkaOutputBuffered
- Defined in:
- lib/fluent/plugin/kafka_plugin_util.rb
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.included(klass) ⇒ Object
4 5 6 7 8 9 10 11 12 13 14 |
# File 'lib/fluent/plugin/kafka_plugin_util.rb', line 4 def self.included(klass) klass.instance_eval { # https://github.com/zendesk/ruby-kafka#encryption-and-authentication-using-ssl config_param :ssl_ca_cert, :string, :default => nil, :desc => "a PEM encoded CA cert to use with and SSL connection." config_param :ssl_client_cert, :string, :default => nil, :desc => "a PEM encoded client cert to use with and SSL connection. Must be used in combination with ssl_client_cert_key." config_param :ssl_client_cert_key, :string, :default => nil, :desc => "a PEM encoded client cert key to use with and SSL connection. Must be used in combination with ssl_client_cert." } end |
Instance Method Details
#read_ssl_file(path) ⇒ Object
16 17 18 19 |
# File 'lib/fluent/plugin/kafka_plugin_util.rb', line 16 def read_ssl_file(path) return nil if path.nil? File.read(path) end |