You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
21 lines
659 B
21 lines
659 B
package consumer
|
|
|
|
const MaxVersionSupported = 1
|
|
|
|
type Subscription struct {
|
|
Version int16 `kafka:"min=v0,max=v1"`
|
|
Topics []string `kafka:"min=v0,max=v1"`
|
|
UserData []byte `kafka:"min=v0,max=v1,nullable"`
|
|
OwnedPartitions []TopicPartition `kafka:"min=v1,max=v1"`
|
|
}
|
|
|
|
type Assignment struct {
|
|
Version int16 `kafka:"min=v0,max=v1"`
|
|
AssignedPartitions []TopicPartition `kafka:"min=v0,max=v1"`
|
|
UserData []byte `kafka:"min=v0,max=v1,nullable"`
|
|
}
|
|
|
|
type TopicPartition struct {
|
|
Topic string `kafka:"min=v0,max=v1"`
|
|
Partitions []int32 `kafka:"min=v0,max=v1"`
|
|
}
|
|
|