kafcat

type ConsumerMessage struct {
	Key, Value string
	Topic      string
	Partition  int32
	Offset     int64
	Timestamp  time.Time // only set if kafka is version 0.10+
}

type Formatter struct {
	Out      io.Writer
	ForceHex bool
}

type LeaderInfo struct {
	ID      int32
	Address string
}

type OffsetInfo struct {
	Oldest int64
	Newest int64
}

type PartitionInfo struct {
	Leader         *LeaderInfo `yaml:",omitempty"`
	Offsets        *OffsetInfo `yaml:",omitempty"`
	Writable       *bool       `yaml:",omitempty"`
	Replicas       []int32     `yaml:",omitempty,flow"`
	InSyncReplicas []int32     `yaml:",omitempty,flow"`
}

type TopicInfo struct {
	Name         string
	Partitions   map[int32]PartitionInfo `yaml:",omitempty"`
	PartitionIds []int32                 `yaml:",omitempty,flow"`
}