Method AddGroupPartition

offset_fetch_request.go:361–371

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

(group, topic string, partitionID int32)

// AddGroupPartition adds a partition under group in a v8+ batch, creating the
// group entry if absent.
func (r *OffsetFetchRequest) AddGroupPartition(group, topic string, partitionID int32) {
	for i := range r.Groups {
		if r.Groups[i].GroupId == group {
			r.Groups[i].AddPartition(topic, partitionID)
			return
		}
	}
	g := OffsetFetchRequestGroup{GroupId: group}
	g.AddPartition(topic, partitionID)
	r.Groups = append(r.Groups, g)
}