瀏覽代碼

fix: MetadataRequest version in DescribeCluster

A very minor fix, but the v1 MetadataRequest (which returns the
controller ID) was actually introduced in Kafka 0.10.0.0 (not 0.11.0.0)
under https://issues.apache.org/jira/browse/KAFKA-3306 so can be used
there.
Dominic Evans 5 年之前
父節點
當前提交
0b7745aace
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      admin.go

+ 1 - 1
admin.go

@@ -216,7 +216,7 @@ func (ca *clusterAdmin) DescribeCluster() (brokers []*Broker, controllerID int32
 		Topics: []string{},
 	}
 
-	if ca.conf.Version.IsAtLeast(V0_11_0_0) {
+	if ca.conf.Version.IsAtLeast(V0_10_0_0) {
 		request.Version = 1
 	}