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 = 1

Types

type ListOffsetsPartitionRequest

type ListOffsetsPartitionRequest struct {
	PartitionIndex int32
	Timestamp      time.Time
}

type ListOffsetsPartitionResponse

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

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
	Topics    []ListOffsetsTopicRequest
}

func (*Request) Version

func (r *Request) Version() int16

type Response

type Response struct {
	Topics []ListOffsetsTopicResponse
}

func (*Response) Version

func (r *Response) Version() int16