(r *bufio.Reader, sz int)
| 268 | } |
| 269 | |
| 270 | func (p *produceResponsePartitionV2) readFrom(r *bufio.Reader, sz int) (remain int, err error) { |
| 271 | if remain, err = readInt32(r, sz, &p.Partition); err != nil { |
| 272 | return |
| 273 | } |
| 274 | if remain, err = readInt16(r, remain, &p.ErrorCode); err != nil { |
| 275 | return |
| 276 | } |
| 277 | if remain, err = readInt64(r, remain, &p.Offset); err != nil { |
| 278 | return |
| 279 | } |
| 280 | if remain, err = readInt64(r, remain, &p.Timestamp); err != nil { |
| 281 | return |
| 282 | } |
| 283 | return |
| 284 | } |
| 285 | |
| 286 | type produceResponsePartitionV7 struct { |
| 287 | Partition int32 |
no test coverage detected