Sha256: ae56ade62ece9e5e7d9081dce0268ef347cede6b96cc74838ee32a260e910e3b
Contents?: true
Size: 837 Bytes
Versions: 9
Compression:
Stored size: 837 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: @sasl_authenticator
)
connection
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems