diff --git a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java index 3e346bb82..fe76fde1b 100644 --- a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java +++ b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java @@ -17,11 +17,15 @@ package org.apache.kafka.connect.runtime.isolation; -import java.util.Collections; import org.junit.Test; -import static org.junit.Assert.assertNotNull; +import java.io.File; +import java.io.FileOutputStream; +import java.io.IOException; +import java.util.Collections; + import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; public class DelegatingClassLoaderTest { @@ -61,4 +65,14 @@ public class DelegatingClassLoaderTest { assertNotNull(classLoader.pluginClassLoader(pluginClassName)); } } + + @Test + public void testLoad() throws IOException { + File file = File.createTempFile("testLoad", ".jar"); + try (FileOutputStream writer = new FileOutputStream(file)) { + writer.write("testLoad".getBytes()); + } + DelegatingClassLoader classLoader = new DelegatingClassLoader(Collections.singletonList(file.getAbsolutePath())); + classLoader.initLoaders(); + } }