class Kafka::BrokerPool

def initialize(connection_builder:, logger:)
  @logger = logger
  @connection_builder = connection_builder
  @brokers = {}
end