Contents

# Represents a broker in a Kafka cluster.
module Kafka
  class BrokerInfo
    attr_reader :node_id, :host, :port

    def initialize(node_id:, host:, port:)
      @node_id = node_id
      @host = host
      @port = port
    end

    def to_s
      "#{host}:#{port} (node_id=#{node_id})"
    end
  end
end

Version data entries

35 entries across 35 versions & 4 rubygems

Version	Path
ruby-kafka-0.7.6.beta2	lib/kafka/broker_info.rb
ruby-kafka-0.7.6.beta1	lib/kafka/broker_info.rb
ruby-kafka-0.7.5	lib/kafka/broker_info.rb
ruby-kafka-0.7.5.beta1	lib/kafka/broker_info.rb
ruby-kafka-0.7.4	lib/kafka/broker_info.rb
ruby-kafka-0.7.3	lib/kafka/broker_info.rb
ruby-kafka-0.7.2	lib/kafka/broker_info.rb
ruby-kafka-0.7.1.debugcorruption2	lib/kafka/broker_info.rb
ruby-kafka-0.7.1.messagecorruptiondebug	lib/kafka/broker_info.rb
ruby-kafka-0.7.1	lib/kafka/broker_info.rb
ruby-kafka-0.7.1.beta2	lib/kafka/broker_info.rb
ruby-kafka-0.7.1.possible.pre.fetch.pre.fix	lib/kafka/broker_info.rb
ruby-kafka-0.7.1.beta1	lib/kafka/broker_info.rb
ruby-kafka-0.7.0	lib/kafka/broker_info.rb
ruby-kafka-0.7.0.beta2	lib/kafka/broker_info.rb