Merge pull request #239 from galasa-dev/fix-noclassdeferror

Move class loader line for Kafka classes at runtime
galasa-dev · Jun 28, 2024 · e3de882 · e3de882
2 parents 7a6df1c + 0ad3676
commit e3de882
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...alasa.events.kafka/src/main/java/dev/galasa/events/kafka/internal/KafkaEventProducer.java b/...alasa.events.kafka/src/main/java/dev/galasa/events/kafka/internal/KafkaEventProducer.java
@@ -21,8 +21,6 @@ public class KafkaEventProducer implements IEventProducer {
 
     public KafkaEventProducer(Properties properties, String topic) {
 
-        Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
-
         KafkaProducer<String, String> producer = new KafkaProducer<String, String>(properties);
         this.producer = producer;
 

diff --git a/...vents.kafka/src/main/java/dev/galasa/events/kafka/internal/KafkaEventProducerFactory.java b/...vents.kafka/src/main/java/dev/galasa/events/kafka/internal/KafkaEventProducerFactory.java
@@ -36,6 +36,9 @@ public Properties createProducerConfig(IConfigurationPropertyStoreService cps, S
         try {
             String bootstrapServers = cps.getProperty("bootstrap", "servers");
 
+            // Needed to get the Kafka classes at runtime
+            Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
+
             properties.put("bootstrap.servers", bootstrapServers);
             properties.put("topic", topic);
             properties.put("key.serializer", StringSerializer.class.getName());