class Kafka::Protocol::ListGroupsResponse

Attributes

error_code[R]
groups[R]

Public Class Methods

decode(decoder) click to toggle source
# File lib/kafka/protocol/list_groups_response.rb, line 22
def self.decode(decoder)
  error_code = decoder.int16
  groups = decoder.array do
    GroupEntry.new(
      group_id: decoder.string,
      protocol_type: decoder.string
    )
  end

  new(error_code: error_code, groups: groups)
end
new(error_code:, groups:) click to toggle source
# File lib/kafka/protocol/list_groups_response.rb, line 17
def initialize(error_code:, groups:)
  @error_code = error_code
  @groups = groups
end