Versions in this module Expand all Collapse all v0 v0.4.36 Sep 6, 2022 v0.4.35 Aug 22, 2022 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
Go to main page