|
@@ -20,7 +20,7 @@ type ClusterAdmin interface {
|
|
|
|
|
|
ListTopics() (map[string]TopicDetail, error)
|
|
|
|
|
|
-
|
|
|
+
|
|
|
DescribeTopics(topics []string) (metadata []*TopicMetadata, err error)
|
|
|
|
|
|
|
|
@@ -78,13 +78,13 @@ type ClusterAdmin interface {
|
|
|
|
|
|
ListConsumerGroups() (map[string]string, error)
|
|
|
|
|
|
-
|
|
|
+
|
|
|
DescribeConsumerGroups(groups []string) ([]*GroupDescription, error)
|
|
|
|
|
|
|
|
|
ListConsumerGroupOffsets(group string, topicPartitions map[string][]int32) (*OffsetFetchResponse, error)
|
|
|
|
|
|
-
|
|
|
+
|
|
|
DescribeCluster() (brokers []*Broker, controllerID int32, err error)
|
|
|
|
|
|
|