class TencentCloud::Dts::V20211206::KafkaOption

目标端为kakfa时添加的同步选项字段

def deserialize(params)

def deserialize(params)
  @DataType = params['DataType']
  @TopicType = params['TopicType']
  @DDLTopicName = params['DDLTopicName']
  unless params['TopicRules'].nil?
    @TopicRules = []
    params['TopicRules'].each do |i|
      topicrule_tmp = TopicRule.new
      topicrule_tmp.deserialize(i)
      @TopicRules << topicrule_tmp
    end
  end
end

def initialize(datatype=nil, topictype=nil, ddltopicname=nil, topicrules=nil)

def initialize(datatype=nil, topictype=nil, ddltopicname=nil, topicrules=nil)
  @DataType = datatype
  @TopicType = topictype
  @DDLTopicName = ddltopicname
  @TopicRules = topicrules
end