Method AddPartition

offset_fetch_request.go:344–357

AddPartition appends a partition to the request. On v8+ it targets Groups[0] (seeded from ConsumerGroup if needed); use AddGroupPartition for v8 batches.

(topic string, partitionID int32)

// AddPartition appends a partition to the request. On v8+ it targets Groups[0]
// (seeded from ConsumerGroup if needed); use AddGroupPartition for v8 batches.
func (r *OffsetFetchRequest) AddPartition(topic string, partitionID int32) {
	if r.Version >= 8 {
		if len(r.Groups) == 0 {
			r.Groups = []OffsetFetchRequestGroup{{GroupId: r.ConsumerGroup}}
		}
		r.Groups[0].AddPartition(topic, partitionID)
		return
	}
	if r.partitions == nil {
		r.partitions = make(map[string][]int32)
	}

	r.partitions[topic] = append(r.partitions[topic], partitionID)
}

// AddGroupPartition adds a partition under group in a v8+ batch, creating the
// group entry if absent.