class Kafka::Client

def initialize_cluster
  broker_pool = BrokerPool.new(
    connection_builder: @connection_builder,
    logger: @logger,
  )
  Cluster.new(
    seed_brokers: @seed_brokers,
    broker_pool: broker_pool,
    logger: @logger,
  )
end