Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Request ¶
type Request struct {
GroupID string `kafka:"min=v0,max=v0"`
Topics []RequestTopic `kafka:"min=v0,max=v0"`
}
type RequestPartition ¶
type RequestPartition struct {
PartitionIndex int32 `kafka:"min=v0,max=v0"`
}
type RequestTopic ¶
type RequestTopic struct {
Name string `kafka:"min=v0,max=v0"`
Partitions []RequestPartition `kafka:"min=v0,max=v0"`
}
type Response ¶
type Response struct {
ErrorCode int16 `kafka:"min=v0,max=v0"`
ThrottleTimeMs int32 `kafka:"min=v0,max=v0"`
Topics []ResponseTopic `kafka:"min=v0,max=v0"`
}
type ResponsePartition ¶
type ResponseTopic ¶
type ResponseTopic struct {
Name string `kafka:"min=v0,max=v0"`
Partitions []ResponsePartition `kafka:"min=v0,max=v0"`
}
Click to show internal directories.
Click to hide internal directories.