Method AddPartition

offset_fetch_request.go:10–15

(topic string, partitionID int32)

}

func (g *OffsetFetchRequestGroup) AddPartition(topic string, partitionID int32) {
	if g.Partitions == nil {
		g.Partitions = make(map[string][]int32)
	}
	g.Partitions[topic] = append(g.Partitions[topic], partitionID)
}

type OffsetFetchRequest struct {
	Version       int16