Versions in this module Expand all Collapse all v0 v0.4.34 Jun 29, 2022 Changes in this version + type Request struct + TimeoutMs int32 + Topics []RequestTopic + ValidateOnly bool + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + type RequestAssignment struct + BrokerIDs []int32 + PartitionIndex int32 + type RequestConfig struct + Name string + Value string + type RequestTopic struct + Assignments []RequestAssignment + Configs []RequestConfig + Name string + NumPartitions int32 + ReplicationFactor int16 + type Response struct + ThrottleTimeMs int32 + Topics []ResponseTopic + func (r *Response) ApiKey() protocol.ApiKey + type ResponseTopic struct + Configs []ResponseTopicConfig + ErrorCode int16 + ErrorMessage string + Name string + NumPartitions int32 + ReplicationFactor int16 + type ResponseTopicConfig struct + ConfigSource int8 + IsSensitive bool + Name string + ReadOnly bool + Value string
Go to main page