alterpartitionreassignments

Apr 9, 2021

Changes in this version

+ type Request struct

+ TimeoutMs int32

+ Topics []RequestTopic

+ func (r *Request) ApiKey() protocol.ApiKey

+ func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error)

+ type RequestPartition struct

+ PartitionIndex int32

+ Replicas []int32

+ type RequestTopic struct

+ Name string

+ Partitions []RequestPartition

+ type Response struct

+ ErrorCode int16

+ ErrorMessage string

+ Results []ResponseResult

+ ThrottleTimeMs int32

+ func (r *Response) ApiKey() protocol.ApiKey

+ type ResponsePartition struct

+ ErrorCode int16

+ ErrorMessage string

+ PartitionIndex int32

+ type ResponseResult struct

+ Name string

+ Partitions []ResponsePartition