v4

Documentation

Index

• Constants
• type Request
  • func (r *Request) Version() int16
• type RequestOffsetFetchTopic
• type Response
  • func (r *Response) Version() int16
• type ResponseOffsetFetchTopic
• type ResponseOffsetFetchTopicPartition

Constants

const Version int16 = 1

Types

type Request

type Request struct {
	GroupID string
	Topics  []RequestOffsetFetchTopic
}

func (*Request) Version

func (r *Request) Version() int16

type RequestOffsetFetchTopic

type RequestOffsetFetchTopic struct {
	Name             string
	PartitionIndexes []int32
}

type Response

type Response struct {
	Topics []ResponseOffsetFetchTopic
}

func (*Response) Version

func (r *Response) Version() int16

type ResponseOffsetFetchTopic

type ResponseOffsetFetchTopic struct {
	Name       string
	Partitions []ResponseOffsetFetchTopicPartition
}

type ResponseOffsetFetchTopicPartition

type ResponseOffsetFetchTopicPartition struct {
	PartitionIndex  int32
	CommittedOffset int64
	Metadata        *string
	ErrCode         errors.KafkaError
}