class TencentCloud::Ckafka::V20190819::FailureParam

数据处理规则失败处理

def deserialize(params) 

def deserialize(params)
  @Type = params['Type']
  unless params['KafkaParam'].nil?
    @KafkaParam = KafkaParam.new
    @KafkaParam.deserialize(params['KafkaParam'])
  end
  @RetryInterval = params['RetryInterval']
  @MaxRetryAttempts = params['MaxRetryAttempts']
  unless params['TopicParam'].nil?
    @TopicParam = TopicParam.new
    @TopicParam.deserialize(params['TopicParam'])
  end
  @DlqType = params['DlqType']
end

def initialize(type=nil, kafkaparam=nil, retryinterval=nil, maxretryattempts=nil, topicparam=nil, dlqtype=nil) 

def initialize(type=nil, kafkaparam=nil, retryinterval=nil, maxretryattempts=nil, topicparam=nil, dlqtype=nil)
  @Type = type
  @KafkaParam = kafkaparam
  @RetryInterval = retryinterval
  @MaxRetryAttempts = maxretryattempts
  @TopicParam = topicparam
  @DlqType = dlqtype
end