Merge pull request #30 from SnuK87/fix/remove-classloader-fix

Remove classloader fix
SnuK87 · Jun 11, 2023 · 070c027 · 070c027
2 parents a81f244 + e41a3c3
commit 070c027
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.github.snuk87.keycloak</groupId>
 	<artifactId>keycloak-kafka</artifactId>
-	<version>1.1.4</version>
+	<version>1.1.5</version>
 
 	<properties>
 		<maven.compiler.source>17</maven.compiler.source>

diff --git a/src/main/java/com/github/snuk87/keycloak/kafka/KafkaStandardProducerFactory.java b/src/main/java/com/github/snuk87/keycloak/kafka/KafkaStandardProducerFactory.java
@@ -18,12 +18,7 @@ public Producer<String, String> createProducer(String clientId, String bootstrap
 		props.put(ProducerConfig.CLIENT_ID_CONFIG, clientId);
 		props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
 		props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
-
-		optionalProperties.forEach(props::put);
-
-		// fix Class org.apache.kafka.common.serialization.StringSerializer could not be
-		// found. see https://stackoverflow.com/a/50981469
-		Thread.currentThread().setContextClassLoader(null);
+		props.putAll(optionalProperties);
 
 		return new KafkaProducer<>(props);
 	}