PLUGIN-551: Confluent Kafka fails with AbstractMethodError

cloudsufi · Mar 1, 2021 · 0b40a75 · 0b40a75
1 parent 4420315
commit 0b40a75
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/confluent-kafka-plugins/pom.xml b/confluent-kafka-plugins/pom.xml
@@ -76,6 +76,10 @@
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
         </exclusion>
+        <exclusion>
+          <groupId>net.jpountz.lz4</groupId>
+          <artifactId>lz4</artifactId>
+        </exclusion>
       </exclusions>
     </dependency>
     <dependency>
@@ -91,6 +95,10 @@
           <groupId>org.apache.spark</groupId>
           <artifactId>spark-tags_2.11</artifactId>
         </exclusion>
+        <exclusion>
+          <groupId>net.jpountz.lz4</groupId>
+          <artifactId>lz4</artifactId>
+        </exclusion>
       </exclusions>
     </dependency>
     <dependency>
@@ -225,6 +233,7 @@
               org.apache.kafka.common.*;
               org.apache.kafka.common.serialization.*;
               io.confluent.kafka.serializers.*;
+              org.apache.kafka.clients.*;
             </_exportcontents>
             <Embed-Dependency>*;inline=false;scope=compile</Embed-Dependency>
             <Embed-Transitive>true</Embed-Transitive>

diff --git a/pom.xml b/pom.xml
@@ -90,7 +90,7 @@
     <cdap.version>6.1.1</cdap.version>
     <cdap.plugin.version>2.3.5</cdap.plugin.version>
     <spark1.version>1.6.1</spark1.version>
-    <spark2.version>2.2.0</spark2.version>
+    <spark2.version>2.3.0</spark2.version>
     <widgets.dir>widgets</widgets.dir>
     <docs.dir>docs</docs.dir>
     <kafka8.version>0.8.2.2</kafka8.version>