Sha256: 5690fc2fc5f0f672969ef3c2a3fdb4bdcb99bd7943b040ed180f679738fb8a68
Contents?: true
Size: 929 Bytes
Versions: 53
Compression:
Stored size: 929 Bytes
Contents
module Fluent
module KafkaPluginUtil
module SSLSettings
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
def read_ssl_file(path)
return nil if path.nil?
File.read(path)
end
end
end
end
Version data entries
53 entries across 53 versions & 2 rubygems