| commit | 2b1b3c576342ae39b8d715b437305a5b3e375660 | [log] [tgz] |
|---|---|---|
| author | David Ostrovsky <david@ostrovsky.org> | Sat Jul 14 08:42:37 2018 +0200 |
| committer | Luca Milanesio <luca.milanesio@gmail.com> | Tue Nov 13 23:43:28 2018 +0000 |
| tree | 57edcbe3476e1ba1b5bf457767ecbb2e49e947be | |
| parent | db2bfddbf48851d376431ddb611e3fbeef5f38d5 [diff] |
KafkaSession: clarify use of ContextClassLoader Change-Id: If2ac679c0efae80aa1cb13d32a4d6d0d3b4a55ce
diff --git a/src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java b/src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java index ae8aa2b..fcb5263 100644 --- a/src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java +++ b/src/main/java/com/googlesource/gerrit/plugins/kafka/session/KafkaSession.java
@@ -47,6 +47,10 @@ } LOGGER.info("Connect to {}...", properties.getProperty("bootstrap.servers")); + /* Need to make sure that the thread of the running connection uses + * the correct class loader otherwize you can endup with hard to debug + * ClassNotFoundExceptions + */ setConnectionClassLoader(); producer = new KafkaProducer<>(properties); LOGGER.info("Connection established.");