types

type Broker struct {
	ID   int
	Host string
	Port int
}

type ConsumerGroup struct {
	Name string
}

type LowHighOffset struct {
	Low  int64 // the earliest offset
	High int64 // the latest offset
}

type Offset struct {
	Topic      string
	Group      string // optional; used only when getting offsets for a consumer group
	Partitions map[int]LowHighOffset
}

type Partition struct {
	ID       int
	Leader   int
	Replicas []int
	Isrs     []int // in-sync replicas
}

type Topic struct {
	Name       string
	Partitions []Partition
}