Module: Fluent::KafkaPluginUtil::SaslSettings

Included in:
Fluent::Kafka2Output, Fluent::KafkaGroupInput, Fluent::KafkaInput, Fluent::KafkaOutput, Fluent::KafkaOutputBuffered, Fluent::KafkaOutputBuffered2, Plugin::RdKafkaGroupInput, Rdkafka2Output
Defined in:
lib/fluent/plugin/kafka_plugin_util.rb

Class Method Summary collapse

Class Method Details

.included(klass) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/fluent/plugin/kafka_plugin_util.rb', line 53

def self.included(klass)
  klass.instance_eval {
    config_param :principal, :string, :default => nil,
                 :desc => "a Kerberos principal to use with SASL authentication (GSSAPI)."
    config_param :keytab, :string, :default => nil,
                 :desc => "a filepath to Kerberos keytab. Must be used with principal."
    config_param :username, :string, :default => nil,
                 :desc => "a username when using PLAIN/SCRAM SASL authentication"
    config_param :password, :string, :default => nil, secret: true,
                 :desc => "a password when using PLAIN/SCRAM SASL authentication"
    config_param :scram_mechanism, :string, :default => nil,
                 :desc => "if set, use SCRAM authentication with specified mechanism. When unset, default to PLAIN authentication"
  }
end