Sha256: c61bdf2d70373387f0c5384840b4e96abff6848490c1710b6cf91e7d15f2b4a5
Contents?: true
Size: 873 Bytes
Versions: 27
Compression:
Stored size: 873 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 = 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
27 entries across 27 versions & 1 rubygems