Sha256: b1ef4a357fa81b27fe1064959c9911e64771bdf1f4805a23f37abe9e039f9ba2
Contents?: true
Size: 891 Bytes
Versions: 22
Compression:
Stored size: 891 Bytes
Contents
# frozen_string_literal: true
module Kafka
class ConnectionBuilder
def initialize(client_id:, logger:, instrumenter:, connect_timeout:, socket_timeout:, ssl_context:, sasl_authenticator:)
@client_id = client_id
@logger = TaggedLogger.new(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
22 entries across 22 versions & 4 rubygems