def METHOD_NAME(self):
    p = self.load_policy({'name': 'kafka', 'resource': 'aws.kafka'})
    resource = load_data('kafka.json')
    results = p.resource_manager.augment([resource])
    self.assertEqual(
        results[0]['Tags'],
        [{'Key': 'ResourceContact', 'Value': 'ouremailaddress@company.com'}])