Class: Kafka::SaslAuthenticator

Inherits:
Object
  • Object
show all
Defined in:
lib/kafka/sasl_authenticator.rb

Instance Method Summary collapse

Constructor Details

#initialize(logger:, sasl_gssapi_principal:, sasl_gssapi_keytab:, sasl_plain_authzid:, sasl_plain_username:, sasl_plain_password:) ⇒ SaslAuthenticator

Returns a new instance of SaslAuthenticator.



6
7
8
9
10
11
12
13
 
# File 'lib/kafka/sasl_authenticator.rb', line 6

def initialize(logger:, sasl_gssapi_principal:, sasl_gssapi_keytab:, sasl_plain_authzid:, sasl_plain_username:, sasl_plain_password:)
  @logger = logger
  @sasl_gssapi_principal = sasl_gssapi_principal
  @sasl_gssapi_keytab = sasl_gssapi_keytab
  @sasl_plain_authzid = sasl_plain_authzid
  @sasl_plain_username = sasl_plain_username
  @sasl_plain_password = sasl_plain_password
end

Instance Method Details

#authenticate!(connection) ⇒ Object 



15
16
17
18
19
20
21
 
# File 'lib/kafka/sasl_authenticator.rb', line 15

def authenticate!(connection)
  if authenticate_using_sasl_gssapi?
    sasl_gssapi_authenticate(connection)
  elsif authenticate_using_sasl_plain?
    sasl_plain_authenticate(connection)
  end
end