class Kafka::Protocol::SyncGroupRequest
def encode(encoder)
def encode(encoder) encoder.write_string(@group_id) encoder.write_int32(@generation_id) encoder.write_string(@member_id) encoder.write_array(@group_assignment) do |member_id, member_assignment| encoder.write_string(member_id) encoder.write_bytes(Encoder.encode_with(member_assignment)) end end