kafka

type GeneralTopicInfo struct {
	Name              string
	NumberMessages    int64
	ReplicationFactor int16
	ReplicaAssignment map[int32][]int32
	ConfigEntries     map[string]*string
	NumberPartitions  int32
}

type JokkConsumer struct {
	MsgChannel chan sarama.ConsumerMessage
	// contains filtered or unexported fields
}

type PartitionChannelInfo struct {
	// contains filtered or unexported fields
}

type PartitionCountInfo struct {
	TotalMessageCount int64
	Partitions        []PartitionInfo
}

type PartitionDetailCountInfo struct {
	TotalMessageCount int64
	Partitions        []PartitionDetailInfo
}

type PartitionDetailInfo struct {
	PartitionInfo   PartitionInfo
	Leader          int32
	Replicas        []int32
	Isr             []int32
	OfflineReplicas []int32
}

type PartitionInfo struct {
	Id                int
	OldOffset         int
	NewOffset         int
	PartitionMsgCount int
}

type TopicDetailInfo struct {
	GeneralTopicInfo    GeneralTopicInfo
	PartionDetailedInfo []PartitionDetailInfo
}

type TopicInfo struct {
	GeneralTopicInfo GeneralTopicInfo
	PartitionsInfo   []PartitionInfo
}