Sha256: bce1603123b5be29385c2d946ebc41c0941096a4f61469ec647471ebf8887f0a
Contents?: true
Size: 712 Bytes
Versions: 14
Compression:
Stored size: 712 Bytes
Contents
# frozen_string_literal: true
module Kafka
module Protocol
class GroupCoordinatorResponse
attr_reader :error_code
attr_reader :coordinator_id, :coordinator_host, :coordinator_port
def initialize(error_code:, coordinator_id:, coordinator_host:, coordinator_port:)
@error_code = error_code
@coordinator_id = coordinator_id
@coordinator_host = coordinator_host
@coordinator_port = coordinator_port
end
def self.decode(decoder)
new(
error_code: decoder.int16,
coordinator_id: decoder.int32,
coordinator_host: decoder.string,
coordinator_port: decoder.int32,
)
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems