lib/v20190819/models.rb in tencentcloud-sdk-ckafka-1.0.364 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.371

@@ -7152,14 +7152,20 @@
         # @type DataTargetInsertMode: String
         # @param DataTargetPrimaryKeyField: 当 "DataInsertMode"="UPSERT" 时，传入当前 upsert 时依赖的主键
         # @type DataTargetPrimaryKeyField: String
         # @param DataTargetRecordMapping: 表与消息间的映射关系
         # @type DataTargetRecordMapping: Array
+        # @param TopicRegex: 事件路由到特定主题的正则表达式，默认为(.*)
+        # @type TopicRegex: String
+        # @param TopicReplacement: TopicRegex的引用组，指定$1、$2等
+        # @type TopicReplacement: String
+        # @param KeyColumns: 格式：库1.表1:字段1,字段2;库2.表2:字段2，表之间;（分号）隔开，字段之间,（逗号）隔开。不指定的表默认取表的主键
+        # @type KeyColumns: String
 
-        attr_accessor :Database, :Table, :Resource, :SnapshotMode, :DdlTopic, :DataSourceMonitorMode, :DataSourceMonitorResource, :DataSourceIncrementMode, :DataSourceIncrementColumn, :DataSourceStartFrom, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping
+        attr_accessor :Database, :Table, :Resource, :SnapshotMode, :DdlTopic, :DataSourceMonitorMode, :DataSourceMonitorResource, :DataSourceIncrementMode, :DataSourceIncrementColumn, :DataSourceStartFrom, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping, :TopicRegex, :TopicReplacement, :KeyColumns
         
-        def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil)
+        def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil)
           @Database = database
           @Table = table
           @Resource = resource
           @SnapshotMode = snapshotmode
           @DdlTopic = ddltopic
@@ -7169,10 +7175,13 @@
           @DataSourceIncrementColumn = datasourceincrementcolumn
           @DataSourceStartFrom = datasourcestartfrom
           @DataTargetInsertMode = datatargetinsertmode
           @DataTargetPrimaryKeyField = datatargetprimarykeyfield
           @DataTargetRecordMapping = datatargetrecordmapping
+          @TopicRegex = topicregex
+          @TopicReplacement = topicreplacement
+          @KeyColumns = keycolumns
         end
 
         def deserialize(params)
           @Database = params['Database']
           @Table = params['Table']
@@ -7192,10 +7201,13 @@
               recordmapping_tmp = RecordMapping.new
               recordmapping_tmp.deserialize(i)
               @DataTargetRecordMapping << recordmapping_tmp
             end
           end
+          @TopicRegex = params['TopicRegex']
+          @TopicReplacement = params['TopicReplacement']
+          @KeyColumns = params['KeyColumns']
         end
       end
 
       # 操作类型返回的Data结构
       class OperateResponseData < TencentCloud::Common::AbstractModel
@@ -8016,24 +8028,32 @@
       class TdwParam < TencentCloud::Common::AbstractModel
         # @param Bid: Tdw的bid
         # @type Bid: String
         # @param Tid: Tdw的tid
         # @type Tid: String
-        # @param IsDomestic: 是否为国内站，默认true
+        # @param IsDomestic: 默认true
         # @type IsDomestic: Boolean
+        # @param TdwHost: TDW地址，默认tl-tdbank-tdmanager.tencent-distribute.com
+        # @type TdwHost: String
+        # @param TdwPort: TDW端口，默认8099
+        # @type TdwPort: Integer
 
-        attr_accessor :Bid, :Tid, :IsDomestic
+        attr_accessor :Bid, :Tid, :IsDomestic, :TdwHost, :TdwPort
         
-        def initialize(bid=nil, tid=nil, isdomestic=nil)
+        def initialize(bid=nil, tid=nil, isdomestic=nil, tdwhost=nil, tdwport=nil)
           @Bid = bid
           @Tid = tid
           @IsDomestic = isdomestic
+          @TdwHost = tdwhost
+          @TdwPort = tdwport
         end
 
         def deserialize(params)
           @Bid = params['Bid']
           @Tid = params['Tid']
           @IsDomestic = params['IsDomestic']
+          @TdwHost = params['TdwHost']
+          @TdwPort = params['TdwPort']
         end
       end
 
       # 返回的topic对象
       class Topic < TencentCloud::Common::AbstractModel