fix ckafka backend change (#1308)

Author: hellertang

tencentcloud/data_source_tc_ckafka_acls_test.go

@@ -49,6 +49,7 @@ resource "tencentcloud_ckafka_topic" "kafka_topic_acl" {
 	unclean_leader_election_enable  = false
 	segment                         = 86400000
 	retention                       = 60000
+	max_message_bytes               = 8388608
 }
 
 resource "tencentcloud_ckafka_acl" foo {

tencentcloud/data_source_tc_ckafka_topics.go

@@ -17,7 +17,7 @@ resource "tencentcloud_ckafka_topic" "foo" {
 	unclean_leader_election_enable  = false
 	segment                         = 3600000
 	retention                       = 60000
-	max_message_bytes               = 0
+	max_message_bytes               = 1024
 }
 ```
 */

tencentcloud/data_source_tc_ckafka_topics_test.go

@@ -54,6 +54,7 @@ resource "tencentcloud_ckafka_topic" "kafka_topic" {
 	unclean_leader_election_enable  = false
 	segment                         = 86400000
 	retention                       = 60000
+	max_message_bytes               = 8388608
 }
 
 data "tencentcloud_ckafka_topics" "kafka_topics" {

tencentcloud/extension_ckafka.go

@@ -70,3 +70,4 @@ var CKAFKA_PERMISSION_TYPE_TO_STRING = map[int64]string{
 
 //sdk ckafka not found error
 const CkafkaInstanceNotFound = "InvalidParameterValue.InstanceNotExist"
+const CkafkaFailedOperation = "FailedOperation"

tencentcloud/resource_tc_ckafka_acl_test.go

@@ -109,6 +109,7 @@ resource "tencentcloud_ckafka_topic" "kafka_topic_acl" {
 	unclean_leader_election_enable  = false
 	segment                         = 86400000
 	retention                       = 60000
+	max_message_bytes               = 8388608
 }
 
 resource "tencentcloud_ckafka_acl" foo {

tencentcloud/resource_tc_ckafka_topic.go

@@ -120,7 +120,8 @@ func resourceTencentCloudCkafkaTopic() *schema.Resource {
 			"max_message_bytes": {
 				Type:        schema.TypeInt,
 				Optional:    true,
-				Description: "Max message bytes.",
+				Computed:    true,
+				Description: "Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).",
 			},
 			"segment": {
 				Type:         schema.TypeInt,
@@ -201,6 +202,9 @@ func resourceTencentCloudCkafkaTopicCreate(d *schema.ResourceData, meta interfac
 			request.SegmentMs = helper.IntInt64(v.(int))
 		}
 	}
+	if v, ok := d.GetOk("max_message_bytes"); ok {
+		request.MaxMessageBytes = helper.IntInt64(v.(int))
+	}
 	request.InstanceId = &instanceId
 	request.TopicName = &topicName
 	request.PartitionNum = helper.IntInt64(d.Get("partition_num").(int))

tencentcloud/resource_tc_ckafka_topic_test.go

@@ -186,7 +186,7 @@ resource "tencentcloud_ckafka_topic" "kafka_topic" {
 	unclean_leader_election_enable      = false
 	segment                             = 86400000
 	retention                           = 60000
-	max_message_bytes                   = 0
+	max_message_bytes                   = 1024
 }
 `
 

tencentcloud/service_tencentcloud_ckafka.go

@@ -461,7 +461,7 @@ func (me *CkafkaService) DescribeInstanceById(ctx context.Context, instanceId st
 		response, err = me.client.UseCkafkaClient().DescribeInstanceAttributes(request)
 		if err != nil {
 			if sdkErr, ok := err.(*errors.TencentCloudSDKError); ok {
-				if sdkErr.Code == CkafkaInstanceNotFound {
+				if sdkErr.Code == CkafkaInstanceNotFound || sdkErr.Code == CkafkaFailedOperation {
 					return nil
 				}
 			}

website/docs/d/ckafka_topics.html.markdown

@@ -27,7 +27,7 @@ resource "tencentcloud_ckafka_topic" "foo" {
   unclean_leader_election_enable = false
   segment                        = 3600000
   retention                      = 60000
-  max_message_bytes              = 0
+  max_message_bytes              = 1024
 }
 ```
 

website/docs/r/ckafka_topic.html.markdown

@@ -42,7 +42,7 @@ The following arguments are supported:
 * `clean_up_policy` - (Optional, String) Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
 * `enable_white_list` - (Optional, Bool) Whether to open the ip whitelist, `true`: open, `false`: close.
 * `ip_white_list` - (Optional, List: [`String`]) Ip whitelist, quota limit, required when enableWhileList=true.
-* `max_message_bytes` - (Optional, Int) Max message bytes.
+* `max_message_bytes` - (Optional, Int) Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
 * `note` - (Optional, String) The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
 * `retention` - (Optional, Int) Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
 * `segment` - (Optional, Int) Segment scrolling time, in ms, the current minimum is 3600000ms.