fix(ckafka): [121324902] support elastic_bandwidth_switch (#3051)

* support elastic_bandwidth_switch

* add changelog

* update

---------

Co-authored-by: mikatong <[email protected]>

Author: tongyiming

.changelog/3051.txt

@@ -0,0 +1,3 @@
+```release-note:enhancement
+resource/tencentcloud_ckafka_instance: support param `elastic_bandwidth_switch`
+```

go.mod

@@ -42,7 +42,7 @@ require (
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cfw v1.0.1018
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/chdfs v1.0.600
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ciam v1.0.695
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.748
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.1073
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.1034
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit v1.0.1033
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls v1.0.1046

go.sum

@@ -862,6 +862,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ciam v1.0.695 h1:FGwsF1
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ciam v1.0.695/go.mod h1:HAasVoWz8ed6kAg7Q/DTg+8uZXiOgW7lmJeAGGrquEQ=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.748 h1:rVvRHow8cFGJFT31sk3cEVW17a9OewHWhC1acUGNg7c=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.748/go.mod h1:nvb4W+PgsAe8NFG1ZevZa9ZLfto3aeBcJqxzYCRI9V4=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.1073 h1:+nTp32YOtwreGWNjbTHglsnxu5pruPyHOosQ1yN/tkE=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/ckafka v1.0.1073/go.mod h1:D9xdyB3utAtgGwTExSGxHSVQMfVHEUo/bfaBTxjHkao=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.1034 h1:nZBr0eJI2iTLSm26QZXNgk4VT3Fxtt+zgXCiCH6avmo=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.1034/go.mod h1:q8fxlV0OQPmG3Zqq4f06m+EOqfU8BvZPnVsPCkCdv6E=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit v1.0.1033 h1:dIr+MVsZeUBiKZELfJh5HRJdI+BI6lCp5pv/2oXekuk=

tencentcloud/services/ckafka/resource_tc_ckafka_instance.go

@@ -268,6 +268,11 @@ func ResourceTencentCloudCkafkaInstance() *schema.Resource {
 				ValidateFunc: tccommon.ValidateIntegerInRange(1024, 12*1024*1024),
 				Description:  "The size of a single message in bytes at the instance level. Value range: `1024 - 12*1024*1024 bytes (i.e., 1KB-12MB).",
 			},
+			"elastic_bandwidth_switch": {
+				Type:        schema.TypeInt,
+				Optional:    true,
+				Description: "Elastic bandwidth switch 0 not turned on 1 turned on (0 default). This takes effect only when the instance is created.",
+			},
 			"vip": {
 				Type:        schema.TypeString,
 				Computed:    true,
@@ -364,6 +369,10 @@ func ckafkaRequestSetParams(request interface{}, d *schema.ResourceData) {
 		}
 		values.FieldByName("ZoneIds").Set(reflect.ValueOf(zoneIds))
 	}
+
+	if v, ok := d.GetOk("elastic_bandwidth_switch"); ok {
+		values.FieldByName("ElasticBandwidthSwitch").Set(reflect.ValueOf(helper.Int64(int64(v.(int)))))
+	}
 }
 
 func createCkafkaInstancePostPaid(ctx context.Context, d *schema.ResourceData, meta interface{}) (instanceId *string, err error) {
@@ -721,7 +730,7 @@ func resourceTencentCloudCkafkaInstanceUpdate(d *schema.ResourceData, meta inter
 		"zone_id", "period", "vpc_id",
 		"subnet_id", "renew_flag", "kafka_version",
 		"multi_zone_flag", "zone_ids", "disk_type",
-		"specifications_type", "instance_type",
+		"specifications_type", "instance_type", "elastic_bandwidth_switch",
 	}
 
 	for _, v := range immutableArgs {

tencentcloud/services/ckafka/resource_tc_ckafka_instance_test.go

@@ -38,6 +38,7 @@ func TestAccTencentCloudCkafkaInstanceResource_prepaid(t *testing.T) {
 					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "disk_type", "CLOUD_BASIC"),
 					resource.TestCheckResourceAttrSet("tencentcloud_ckafka_instance.kafka_instance", "vip"),
 					resource.TestCheckResourceAttrSet("tencentcloud_ckafka_instance.kafka_instance", "vport"),
+					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "elastic_bandwidth_switch", "1"),
 				),
 			},
 			{
@@ -54,6 +55,7 @@ func TestAccTencentCloudCkafkaInstanceResource_prepaid(t *testing.T) {
 					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "kafka_version", "1.1.1"),
 					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "disk_size", "300"),
 					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "disk_type", "CLOUD_BASIC"),
+					resource.TestCheckResourceAttr("tencentcloud_ckafka_instance.kafka_instance", "elastic_bandwidth_switch", "1"),
 				),
 			},
 			{
@@ -63,7 +65,7 @@ func TestAccTencentCloudCkafkaInstanceResource_prepaid(t *testing.T) {
 				ResourceName:            "tencentcloud_ckafka_instance.kafka_instance",
 				ImportState:             true,
 				ImportStateVerify:       true,
-				ImportStateVerifyIgnore: []string{"period", "max_message_byte", "upgrade_strategy"},
+				ImportStateVerifyIgnore: []string{"period", "max_message_byte", "upgrade_strategy", "elastic_bandwidth_switch"},
 			},
 		},
 	})
@@ -113,7 +115,7 @@ func TestAccTencentCloudCkafkaInstanceResource_postpaid(t *testing.T) {
 				ResourceName:            "tencentcloud_ckafka_instance.kafka_instance_postpaid",
 				ImportState:             true,
 				ImportStateVerify:       true,
-				ImportStateVerifyIgnore: []string{"period", "max_message_byte", "upgrade_strategy"},
+				ImportStateVerifyIgnore: []string{"period", "max_message_byte", "upgrade_strategy", "elastic_bandwidth_switch"},
 			},
 		},
 	})
@@ -257,7 +259,7 @@ resource "tencentcloud_ckafka_instance" "kafka_instance" {
   band_width         = 20
   disk_type          = "CLOUD_BASIC"
   partition          = 400
-
+  elastic_bandwidth_switch = 1
 
   config {
     auto_create_topic_enable   = true
@@ -299,7 +301,7 @@ resource "tencentcloud_ckafka_instance" "kafka_instance" {
   band_width         = 20
   disk_type          = "CLOUD_BASIC"
   partition          = 400
-
+  elastic_bandwidth_switch = 1
 
   config {
     auto_create_topic_enable   = true