module Fluent::KafkaPluginUtil::SSLSettings
Public Class Methods
included(klass)
click to toggle source
# 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, :array, :value_type => :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." config_param :ssl_ca_certs_from_system, :bool, :default => false, :desc => "this configures the store to look up CA certificates from the system default certificate store on an as needed basis. The location of the store can usually be determined by: OpenSSL::X509::DEFAULT_CERT_FILE." } end
Public Instance Methods
pickup_ssl_endpoint(node)
click to toggle source
# File lib/fluent/plugin/kafka_plugin_util.rb, line 28 def pickup_ssl_endpoint(node) ssl_endpoint = node['endpoints'].find {|e| e.start_with?('SSL')} raise 'no SSL endpoint found on Zookeeper' unless ssl_endpoint return [URI.parse(ssl_endpoint).host, URI.parse(ssl_endpoint).port].join(':') end
read_ssl_file(path)
click to toggle source
# File lib/fluent/plugin/kafka_plugin_util.rb, line 18 def read_ssl_file(path) return nil if path.nil? if path.is_a?(Array) path.map { |fp| File.read(fp) } else File.read(path) end end