(r *bufio.Reader, size int)
| 229 | } |
| 230 | |
| 231 | func (t *offsetCommitResponseV2PartitionResponse) readFrom(r *bufio.Reader, size int) (remain int, err error) { |
| 232 | if remain, err = readInt32(r, size, &t.Partition); err != nil { |
| 233 | return |
| 234 | } |
| 235 | if remain, err = readInt16(r, remain, &t.ErrorCode); err != nil { |
| 236 | return |
| 237 | } |
| 238 | return |
| 239 | } |
| 240 | |
| 241 | type offsetCommitResponseV2Response struct { |
| 242 | Topic string |