class TencentCloud::Ckafka::V20190819::KafkaParam

def deserialize(params)
  @SelfBuilt = params['SelfBuilt']
  @Resource = params['Resource']
  @Topic = params['Topic']
  @OffsetType = params['OffsetType']
  @StartTime = params['StartTime']
  @ResourceName = params['ResourceName']
  @ZoneId = params['ZoneId']
  @TopicId = params['TopicId']
  @PartitionNum = params['PartitionNum']
  @EnableToleration = params['EnableToleration']
  @QpsLimit = params['QpsLimit']
  unless params['TableMappings'].nil?
    @TableMappings = []
    params['TableMappings'].each do |i|
      tablemapping_tmp = TableMapping.new
      tablemapping_tmp.deserialize(i)
      @TableMappings << tablemapping_tmp
    end
  end
  @UseTableMapping = params['UseTableMapping']
  @UseAutoCreateTopic = params['UseAutoCreateTopic']
  @CompressionType = params['CompressionType']
  @MsgMultiple = params['MsgMultiple']
  @ConnectorSyncType = params['ConnectorSyncType']
  @KeepPartition = params['KeepPartition']
end

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
  @ResourceName = resourcename
  @ZoneId = zoneid
  @TopicId = topicid
  @PartitionNum = partitionnum
  @EnableToleration = enabletoleration
  @QpsLimit = qpslimit
  @TableMappings = tablemappings
  @UseTableMapping = usetablemapping
  @UseAutoCreateTopic = useautocreatetopic
  @CompressionType = compressiontype
  @MsgMultiple = msgmultiple
  @ConnectorSyncType = connectorsynctype
  @KeepPartition = keeppartition
end