Versions in this module Expand all Collapse all v0 v0.4.28 Feb 4, 2023 Changes in this version + type Request struct + ElectionType int8 + TimeoutMs int32 + TopicPartitions []RequestTopicPartitions + func (r *Request) ApiKey() protocol.ApiKey + func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) + type RequestTopicPartitions struct + PartitionIDs []int32 + Topic string + type Response struct + ErrorCode int16 + ReplicaElectionResults []ResponseReplicaElectionResult + ThrottleTime int32 + func (r *Response) ApiKey() protocol.ApiKey + type ResponsePartitionResult struct + ErrorCode int16 + ErrorMessage string + PartitionID int32 + type ResponseReplicaElectionResult struct + PartitionResults []ResponsePartitionResult + Topic string
Go to main page