Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Request ¶
type Request struct {
ElectionType int8 `kafka:"min=v1,max=v1"`
TopicPartitions []RequestTopicPartitions `kafka:"min=v0,max=v1"`
TimeoutMs int32 `kafka:"min=v0,max=v1"`
}
Detailed API definition: https://kafka.apache.org/protocol#The_Messages_ElectLeaders
type RequestTopicPartitions ¶
type Response ¶
type Response struct {
ThrottleTime int32 `kafka:"min=v0,max=v1"`
ErrorCode int16 `kafka:"min=v1,max=v1"`
ReplicaElectionResults []ResponseReplicaElectionResult `kafka:"min=v0,max=v1"`
}
type ResponsePartitionResult ¶
type ResponseReplicaElectionResult ¶
type ResponseReplicaElectionResult struct {
Topic string `kafka:"min=v0,max=v1"`
PartitionResults []ResponsePartitionResult `kafka:"min=v0,max=v1"`
}
Click to show internal directories.
Click to hide internal directories.