v4

Documentation

Index

• Constants
• type OffsetCommitPartitionRequest
• type OffsetCommitPartitionResponse
• type OffsetCommitTopicRequest
• type OffsetCommitTopicResponse
• type Request
  • func (r *Request) Version() int16
• type Response
  • func (r *Response) Version() int16

Constants

const Version int16 = 2

Types

type OffsetCommitPartitionRequest

type OffsetCommitPartitionRequest struct {
	PartitionIndex    int32
	CommittedOffset   int64
	CommittedMetadata *string
}

type OffsetCommitPartitionResponse

type OffsetCommitPartitionResponse struct {
	PartitionIndex int32
	ErrCode        errors.KafkaError
}

type OffsetCommitTopicRequest

type OffsetCommitTopicRequest struct {
	Name       string
	Partitions []OffsetCommitPartitionRequest
}

type OffsetCommitTopicResponse

type OffsetCommitTopicResponse struct {
	Name       string
	Partitions []OffsetCommitPartitionResponse
}

type Request

type Request struct {
	GroupID       string
	GenerationID  int32
	MemberID      string
	RetentionTime time.Duration
	Topics        []OffsetCommitTopicRequest
}

func (*Request) Version

func (r *Request) Version() int16

type Response

type Response struct {
	Topics []OffsetCommitTopicResponse
}

func (*Response) Version

func (r *Response) Version() int16