v8

Documentation

Index

• Constants
• type Brokers
• type Partitions
• type Request
  • func (r *Request) Version() int16
• type Response
  • func (r *Response) Version() int16
• type Topics

Constants

const Version int16 = 8

Types

type Brokers

type Brokers struct {
	ID   int32
	Host string
	Port int32
	Rack *string
}

type Partitions

type Partitions struct {
	ErrCode         errors.KafkaError
	Index           int32
	LeaderID        int32
	LeaderEpoch     int32
	ReplicaNodes    []int32
	ISRNodes        []int32
	OfflineReplicas []int32
}

type Request

type Request struct {
	Topics                             []string
	AllowAutoTopicCreation             bool
	IncludeClusterAuthorizedOperations bool
	IncludeTopicAuthorizedOperations   bool
}

func (*Request) Version

func (r *Request) Version() int16

type Response

type Response struct {
	ThrottleDuration            time.Duration
	Brokers                     []Brokers
	ClusterID                   *string
	ControllerID                int32
	Topics                      []Topics
	ClusterAuthorizedOperations int32
}

func (*Response) Version

func (r *Response) Version() int16

type Topics

type Topics struct {
	ErrCode                   errors.KafkaError
	Name                      string
	Internal                  bool
	Partitions                []Partitions
	TopicAuthorizedOperations int32
}