v5

Documentation

Index

• Constants
• type ListOffsetsPartitionRequest
• type ListOffsetsPartitionResponse
• type ListOffsetsTopicRequest
• type ListOffsetsTopicResponse
• type Request
  • func (r *Request) Version() int16
• type Response
  • func (r *Response) Version() int16

Constants

const Version int16 = 5

Types

type ListOffsetsPartitionRequest

type ListOffsetsPartitionRequest struct {
	PartitionIndex     int32
	CurrentLeaderEpoch int32
	Timestamp          time.Time
}

type ListOffsetsPartitionResponse

type ListOffsetsPartitionResponse struct {
	PartitionIndex int32
	ErrCode        errors.KafkaError
	Timestamp      time.Time
	Offset         int64
	LeaderEpoch    int32
}

type ListOffsetsTopicRequest

type ListOffsetsTopicRequest struct {
	Name       string
	Partitions []ListOffsetsPartitionRequest
}

type ListOffsetsTopicResponse

type ListOffsetsTopicResponse struct {
	Name       string
	Partitions []ListOffsetsPartitionResponse
}

type Request

type Request struct {
	ReplicaID      int32
	IsolationLevel int8
	Topics         []ListOffsetsTopicRequest
}

func (*Request) Version

func (r *Request) Version() int16

type Response

type Response struct {
	ThrottleDuration time.Duration
	Topics           []ListOffsetsTopicResponse
}

func (*Response) Version

func (r *Response) Version() int16