(r *bufio.Reader, size int)
| 214 | } |
| 215 | |
| 216 | func (t *groupMetadata) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 217 | if remain, err = readInt16(r, size, &t.Version); err != nil { |
| 218 | return |
| 219 | } |
| 220 | if remain, err = readStringArray(r, remain, &t.Topics); err != nil { |
| 221 | return |
| 222 | } |
| 223 | if remain, err = readBytes(r, remain, &t.UserData); err != nil { |
| 224 | return |
| 225 | } |
| 226 | return |
| 227 | } |
| 228 | |
| 229 | type joinGroupRequestGroupProtocolV1 struct { |
| 230 | ProtocolName string |