diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/AWSResourceManager.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/AWSResourceManager.java index 4a6bcfaf..0d4ba656 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/AWSResourceManager.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/utils/AWSResourceManager.java @@ -65,7 +65,10 @@ public abstract class AWSResourceManager { public void deleteAllResource() throws Exception { final List resourceNames = getAllResourceNames(); for (String resourceName : resourceNames) { - deleteResource(resourceName); + // Delete all resources that have prefix "KCLRelease" + if (resourceName.startsWith("KCLRelease")) { + deleteResource(resourceName); + } } } }