Sha256: 046da90a62c8a643812e3007ffa0a3a4865c5e95ca0d21e2327de49eea574e0c
Contents?: true
Size: 305 Bytes
Versions: 35
Compression:
Stored size: 305 Bytes
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