lib/kafka/cluster.rb
# Initializes a Cluster with a set of seed brokers.
#
# The cluster will try to fetch cluster metadata from one of the brokers.
#
# @param seed_brokers [Array<URI>]
# @param broker_pool [Kafka::BrokerPool]
# @param logger [Logger]
# @param resolve_seed_brokers [Boolean] See {Kafka::Client#initialize}
Initializes a Cluster with a set of seed brokers.
The cluster will try to fetch cluster metadata from one of the brokers.
Initializes a Cluster with a set of seed brokers . The cluster will try to fetch cluster metadata from one of the brokers .
def connect_to_broker(broker_id)
      info = cluster_info.find_broker(broker_id)
      @broker_pool.connect(info.host, info.port, node_id: info.node_id)
    end
def connect_to_broker ( broker_id ) info = cluster_info . find_broker ( broker_id ) @broker_pool . connect ( info . host , info . port , node_id : info . node_id ) end
Initializes a Cluster with a set of seed brokers.
Initializes a Cluster with a set of seed brokers .
broker_id
None
resolve_seed_brokers
None