Method: Kafka::Protocol::MetadataResponse#find_broker

Defined in:

lib/kafka/protocol/metadata_response.rb

#find_broker(node_id) ⇒ Kafka::BrokerInfo

Finds the broker info for the given node id.

Parameters:

• node_id (Integer) —

  the node id of the broker.

Returns:

• (Kafka::BrokerInfo) —

  information about the broker.

Raises:

• (Kafka::NoSuchBroker)

# File 'lib/kafka/protocol/metadata_response.rb', line 115

def find_broker(node_id)
  broker = @brokers.find {|b| b.node_id == node_id }

  raise Kafka::NoSuchBroker, "No broker with id #{node_id}" if broker.nil?

  broker
end