Method decode

offset_request.go:28–51

(pd packetDecoder, version int16)

}

func (b *offsetRequestBlock) decode(pd packetDecoder, version int16) (err error) {
	b.currentLeaderEpoch = -1
	if version >= 4 {
		if b.currentLeaderEpoch, err = pd.getInt32(); err != nil {
			return err
		}
	}

	if b.timestamp, err = pd.getInt64(); err != nil {
		return err
	}

	if version == 0 {
		if b.maxNumOffsets, err = pd.getInt32(); err != nil {
			return err
		}
	}

	if _, err = pd.getEmptyTaggedFieldArray(); err != nil {
		return err
	}

	return nil
}

type OffsetRequest struct {
	Version        int16