Struct Request

protocol/fetch/fetch.go:13–24

}

type Request struct {
	ReplicaID       int32                   `kafka:"min=v0,max=v11"`
	MaxWaitTime     int32                   `kafka:"min=v0,max=v11"`
	MinBytes        int32                   `kafka:"min=v0,max=v11"`
	MaxBytes        int32                   `kafka:"min=v3,max=v11"`
	IsolationLevel  int8                    `kafka:"min=v4,max=v11"`
	SessionID       int32                   `kafka:"min=v7,max=v11"`
	SessionEpoch    int32                   `kafka:"min=v7,max=v11"`
	Topics          []RequestTopic          `kafka:"min=v0,max=v11"`
	ForgottenTopics []RequestForgottenTopic `kafka:"min=v7,max=v11"`
	RackID          string                  `kafka:"min=v11,max=v11"`
}

func (r *Request) ApiKey() protocol.ApiKey { return protocol.Fetch }