diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/session/type/KafkaSession.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/session/type/KafkaSession.java
index 6cd9ad7..b5a16df 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/kafka/session/type/KafkaSession.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/session/type/KafkaSession.java
@@ -51,10 +51,16 @@
 
     LOGGER.info("Connect to {}...",
         properties.getProperty("bootstrap.servers"));
+    setConnectionClassLoader();
     producer = new KafkaProducer<>(properties);
     LOGGER.info("Connection established.");
   }
 
+  private void setConnectionClassLoader() {
+    Thread.currentThread().setContextClassLoader(
+        KafkaSession.class.getClassLoader());
+  }
+
   @Override
   public void disconnect() {
     LOGGER.info("Disconnecting...");