| 304 | } |
| 305 | |
| 306 | func (p *produceResponsePartitionV7) readFrom(r *bufio.Reader, sz int) (remain int, err error) { |
| 307 | if remain, err = readInt32(r, sz, &p.Partition); err != nil { |
| 308 | return |
| 309 | } |
| 310 | if remain, err = readInt16(r, remain, &p.ErrorCode); err != nil { |
| 311 | return |
| 312 | } |
| 313 | if remain, err = readInt64(r, remain, &p.Offset); err != nil { |
| 314 | return |
| 315 | } |
| 316 | if remain, err = readInt64(r, remain, &p.Timestamp); err != nil { |
| 317 | return |
| 318 | } |
| 319 | if remain, err = readInt64(r, remain, &p.StartOffset); err != nil { |
| 320 | return |
| 321 | } |
| 322 | return |
| 323 | } |