Method Encode

protocol/fetch_request.go:22–42

(e PacketEncoder)

}

func (r *FetchRequest) Encode(e PacketEncoder) error {
	if r.ReplicaID == 0 {
		e.PutInt32(-1) // replica ID is -1 for clients
	} else {
		e.PutInt32(r.ReplicaID)
	}
	e.PutInt32(r.MaxWaitTime)
	e.PutInt32(r.MinBytes)
	// e.PutInt32(r.MaxBytes)
	e.PutArrayLength(len(r.Topics))
	for _, t := range r.Topics {
		e.PutString(t.Topic)
		e.PutArrayLength(len(t.Partitions))
		for _, p := range t.Partitions {
			e.PutInt32(p.Partition)
			e.PutInt64(p.FetchOffset)
			e.PutInt32(p.MaxBytes)
		}
	}
	return nil
}

func (r *FetchRequest) Decode(d PacketDecoder) error {
	var err error