lib/kafka/protocol/group_coordinator_response.rb
# 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