Sha256: 443ed97a83bd5ea5dd848afafc3703fb3a443daf9190f41a268541baa5ebbd31
Contents?: true
Size: 842 Bytes
Versions: 15
Compression:
Stored size: 842 Bytes
Contents
module Kafka
class ConnectionBuilder
def initialize(client_id:, logger:, instrumenter:, connect_timeout:, socket_timeout:, ssl_context:, sasl_authenticator:)
@client_id = client_id
@logger = logger
@instrumenter = instrumenter
@connect_timeout = connect_timeout
@socket_timeout = socket_timeout
@ssl_context = ssl_context
@sasl_authenticator = sasl_authenticator
end
def build_connection(host, port)
connection = Connection.new(
host: host,
port: port,
client_id: @client_id,
connect_timeout: @connect_timeout,
socket_timeout: @socket_timeout,
logger: @logger,
instrumenter: @instrumenter,
ssl_context: @ssl_context,
)
@sasl_authenticator.authenticate!(connection)
connection
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems