class Kafka::Protocol::DescribeGroupsResponse
Attributes
error_code[R]
groups[R]
Public Class Methods
decode(decoder)
click to toggle source
# File lib/kafka/protocol/describe_groups_response.rb, line 36 def self.decode(decoder) groups = decoder.array do error_code = decoder.int16 group_id = decoder.string state = decoder.string protocol_type = decoder.string protocol = decoder.string members = decoder.array do member_id = decoder.string client_id = decoder.string client_host = decoder.string _metadata = decoder.bytes assignment = MemberAssignment.decode(Decoder.from_string(decoder.bytes)) Member.new( member_id: member_id, client_id: client_id, client_host: client_host, member_assignment: assignment ) end Group.new( error_code: error_code, group_id: group_id, state: state, protocol_type: protocol_type, protocol: protocol, members: members ) end new(groups: groups) end
new(groups:)
click to toggle source
# File lib/kafka/protocol/describe_groups_response.rb, line 32 def initialize(groups:) @groups = groups end