Fixed #945 Kafka resource

JumpMind · May 15, 2020 · 3e6edb4 · 3e6edb4
1 parent 06e5976
commit 3e6edb4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...rce-core/src/main/java/org/jumpmind/metl/core/runtime/resource/KafkaProducerResource.java b/...rce-core/src/main/java/org/jumpmind/metl/core/runtime/resource/KafkaProducerResource.java
@@ -52,6 +52,7 @@ public void start(Resource resource, TypedProperties resourceRuntimeSettings) {
 
 		setProperties(resourceRuntimeSettings);
 		if (properties.get(SETTING_BOOTSTRAP_SERVERS) != null) {
+			Thread.currentThread().setContextClassLoader(null);
 			producer = new KafkaProducer(properties);
 		}
 	}