class TencentCloud::Ckafka::V20190819::EsParam

def deserialize(params)
  @Resource = params['Resource']
  @Port = params['Port']
  @UserName = params['UserName']
  @Password = params['Password']
  @SelfBuilt = params['SelfBuilt']
  @ServiceVip = params['ServiceVip']
  @UniqVpcId = params['UniqVpcId']
  @DropInvalidMessage = params['DropInvalidMessage']
  @Index = params['Index']
  @DateFormat = params['DateFormat']
  @ContentKey = params['ContentKey']
  @DropInvalidJsonMessage = params['DropInvalidJsonMessage']
  @DocumentIdField = params['DocumentIdField']
  @IndexType = params['IndexType']
  unless params['DropCls'].nil?
    @DropCls = DropCls.new
    @DropCls.deserialize(params['DropCls'])
  end
  @DatabasePrimaryKey = params['DatabasePrimaryKey']
  unless params['DropDlq'].nil?
    @DropDlq = FailureParam.new
    @DropDlq.deserialize(params['DropDlq'])
  end
end

def initialize(resource=nil, port=nil, username=nil, password=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, dropinvalidmessage=nil, index=nil, dateformat=nil, contentkey=nil, dropinvalidjsonmessage=nil, documentidfield=nil, indextype=nil, dropcls=nil, databaseprimarykey=nil, dropdlq=nil)
  @Resource = resource
  @Port = port
  @UserName = username
  @Password = password
  @SelfBuilt = selfbuilt
  @ServiceVip = servicevip
  @UniqVpcId = uniqvpcid
  @DropInvalidMessage = dropinvalidmessage
  @Index = index
  @DateFormat = dateformat
  @ContentKey = contentkey
  @DropInvalidJsonMessage = dropinvalidjsonmessage
  @DocumentIdField = documentidfield
  @IndexType = indextype
  @DropCls = dropcls
  @DatabasePrimaryKey = databaseprimarykey
  @DropDlq = dropdlq
end