Method AddBlock

fetch_request.go:344–369

(topic string, partitionID int32, fetchOffset int64, maxBytes int32, leaderEpoch int32)

}

func (r *FetchRequest) AddBlock(topic string, partitionID int32, fetchOffset int64, maxBytes int32, leaderEpoch int32) {
	if r.blocks == nil {
		r.blocks = make(map[string]map[int32]*fetchRequestBlock)
	}

	if r.Version >= 7 && r.forgotten == nil {
		r.forgotten = make(map[string][]int32)
	}

	if r.blocks[topic] == nil {
		r.blocks[topic] = make(map[int32]*fetchRequestBlock)
	}

	tmp := new(fetchRequestBlock)
	tmp.Version = r.Version
	tmp.maxBytes = maxBytes
	tmp.fetchOffset = fetchOffset
	if r.Version >= 12 {
		tmp.lastFetchedEpoch = -1
	}
	if r.Version >= 9 {
		tmp.currentLeaderEpoch = leaderEpoch
	}

	r.blocks[topic][partitionID] = tmp
}