Sha256: bda905eb81e09ac1edea9eebe3b65a89d86e7eb58e44bf9de4f03132836fa306
Contents?: true
Size: 745 Bytes
Versions: 15
Compression:
Stored size: 745 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
# SaslHandshake Request (Version: 0) => mechanism
# mechanism => string
class SaslHandshakeRequest
SUPPORTED_MECHANISMS = %w(GSSAPI PLAIN SCRAM-SHA-256 SCRAM-SHA-512 OAUTHBEARER)
def initialize(mechanism)
unless SUPPORTED_MECHANISMS.include?(mechanism)
raise Kafka::Error, "Unsupported SASL mechanism #{mechanism}. Supported are #{SUPPORTED_MECHANISMS.join(', ')}"
end
@mechanism = mechanism
end
def api_key
SASL_HANDSHAKE_API
end
def response_class
SaslHandshakeResponse
end
def encode(encoder)
encoder.write_string(@mechanism)
end
end
end
end
Version data entries
15 entries across 15 versions & 3 rubygems