ソースを参照

Merge pull request #1277 from Mongey/cm-fix-describe-request

Set correct Kafka version for DescribeConfigsRequest v1
Vlad Gorodetsky 7 年 前
コミット
5ea7b6f75f
1 ファイル変更1 行追加1 行削除
  1. 1 1
      describe_configs_request.go

+ 1 - 1
describe_configs_request.go

@@ -103,7 +103,7 @@ func (r *DescribeConfigsRequest) version() int16 {
 func (r *DescribeConfigsRequest) requiredVersion() KafkaVersion {
 func (r *DescribeConfigsRequest) requiredVersion() KafkaVersion {
 	switch r.Version {
 	switch r.Version {
 	case 1:
 	case 1:
-		return V1_0_0_0
+		return V1_1_0_0
 	case 2:
 	case 2:
 		return V2_0_0_0
 		return V2_0_0_0
 	default:
 	default: