lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.534 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.535

@@ -7493,14 +7493,20 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type CompressionType: String
         # @param MsgMultiple: 源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用)
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type MsgMultiple: Integer
+        # @param ConnectorSyncType: 数据同步专用参数, 正常数据处理可为空, 实例级别同步: 仅同步元数据填写"META_SYNC_INSTANCE_TYPE", 同步元数据及全部topic内消息的填写"META_AND_DATA_SYNC_INSTANCE_TYPE"; topic级别同步: 选中的源和目标topic中的消息(需要目标实例也包含该topic)填写"DATA_SYNC_TYPE"
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type ConnectorSyncType: String
+        # @param KeepPartition: 数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type KeepPartition: Boolean
 
-        attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType, :MsgMultiple
+        attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType, :MsgMultiple, :ConnectorSyncType, :KeepPartition
         
-        def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil, useautocreatetopic=nil, compressiontype=nil, msgmultiple=nil)
+        def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil, useautocreatetopic=nil, compressiontype=nil, msgmultiple=nil, connectorsynctype=nil, keeppartition=nil)
           @SelfBuilt = selfbuilt
           @Resource = resource
           @Topic = topic
           @OffsetType = offsettype
           @StartTime = starttime
@@ -7513,10 +7519,12 @@
           @TableMappings = tablemappings
           @UseTableMapping = usetablemapping
           @UseAutoCreateTopic = useautocreatetopic
           @CompressionType = compressiontype
           @MsgMultiple = msgmultiple
+          @ConnectorSyncType = connectorsynctype
+          @KeepPartition = keeppartition
         end
 
         def deserialize(params)
           @SelfBuilt = params['SelfBuilt']
           @Resource = params['Resource']
@@ -7539,9 +7547,11 @@
           end
           @UseTableMapping = params['UseTableMapping']
           @UseAutoCreateTopic = params['UseAutoCreateTopic']
           @CompressionType = params['CompressionType']
           @MsgMultiple = params['MsgMultiple']
+          @ConnectorSyncType = params['ConnectorSyncType']
+          @KeepPartition = params['KeepPartition']
         end
       end
 
       # 小写字符解析
       class LowercaseParam < TencentCloud::Common::AbstractModel