MCPcopy
hub / github.com/segmentio/kafka-go / Request

Struct Request

protocol/electleaders/electleaders.go:10–14  ·  view source on GitHub ↗

Detailed API definition: https://kafka.apache.org/protocol#The_Messages_ElectLeaders

Source from the content-addressed store, hash-verified

8
9// Detailed API definition: https://kafka.apache.org/protocol#The_Messages_ElectLeaders
10type Request struct {
11 ElectionType int8 `kafka:"min=v1,max=v1"`
12 TopicPartitions []RequestTopicPartitions `kafka:"min=v0,max=v1"`
13 TimeoutMs int32 `kafka:"min=v0,max=v1"`
14}
15
16type RequestTopicPartitions struct {
17 Topic string `kafka:"min=v0,max=v1"`

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected