client

type KafkaClient interface {
	ListTopics() ([]*models.Topic, error)
	CreateTopic(name string, partitions int32, replication int16) error
	DeleteTopic(name string) error
	DescribeTopic(name string) (*models.TopicDesc, error)
	ListNodes() ([]*models.Node, error)
	ListGroups() ([]*models.Group, error)
	DescribeGroup(name string) (*models.GroupDesc, error)
}