diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java index 693972c1989..d1829b731dc 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java @@ -22,9 +22,11 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.net.URL; import java.net.URLClassLoader; +import java.util.ArrayList; +import java.util.Collections; import java.util.Enumeration; +import java.util.List; import java.util.Objects; -import java.util.Vector; /** * A custom classloader dedicated to loading Connect plugin classes in classloading isolation. @@ -87,7 +89,7 @@ public class PluginClassLoader extends URLClassLoader { @Override public Enumeration getResources(String name) throws IOException { Objects.requireNonNull(name); - Vector resources = new Vector<>(); + List resources = new ArrayList<>(); for (Enumeration foundLocally = findResources(name); foundLocally.hasMoreElements();) { URL url = foundLocally.nextElement(); if (url != null) @@ -99,7 +101,7 @@ public class PluginClassLoader extends URLClassLoader { if (url != null) resources.add(url); } - return resources.elements(); + return Collections.enumeration(resources); } // This method needs to be thread-safe because it is supposed to be called by multiple