class Kafka::Cluster

def initialize(seed_brokers:, broker_pool:, logger:)
  if seed_brokers.empty?
    raise ArgumentError, "At least one seed broker must be configured"
  end
  @logger = logger
  @seed_brokers = seed_brokers
  @broker_pool = broker_pool
  @cluster_info = nil
  @stale = true
  # This is the set of topics we need metadata for. If empty, metadata for
  # all topics will be fetched.
  @target_topics = Set.new
end