Sha256: 1a3e1785f97a7d4a4cecc713896da45b3b649d326b266c839961076a031c641b
Contents?: true
Size: 689 Bytes
Versions: 23
Compression:
Stored size: 689 Bytes
Contents
module Kafka
class ConnectionBuilder
def initialize(client_id:, logger:, instrumenter:, connect_timeout:, socket_timeout:, ssl_context:)
@client_id = client_id
@logger = logger
@instrumenter = instrumenter
@connect_timeout = connect_timeout
@socket_timeout = socket_timeout
@ssl_context = ssl_context
end
def build_connection(host, port)
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,
)
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems