upgrade to confluent 5.3.0

jetoile · Aug 20, 2019 · de76cf2 · de76cf2
1 parent 24c150a
commit de76cf2
Show file tree

Hide file tree

Showing 6 changed files with 439 additions and 145 deletions.
diff --git a/hadoop-unit-confluent-rest/pom.xml b/hadoop-unit-confluent-rest/pom.xml
@@ -41,13 +41,13 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka_2.12</artifactId>
-            <version>1.1.0</version>
+            <version>${confluent_kafka.version}</version>
         </dependency>
 
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
-            <version>1.1.0</version>
+            <version>${confluent_kafka.version}</version>
         </dependency>
 
 
@@ -70,7 +70,7 @@
         <dependency>
             <groupId>org.eclipse.jetty</groupId>
             <artifactId>jetty-util</artifactId>
-            <version>9.4.14.v20181114</version>
+            <version>9.4.18.v20190429</version>
         </dependency>
 
         <dependency>

diff --git a/hadoop-unit-confluent/pom.xml b/hadoop-unit-confluent/pom.xml
@@ -77,7 +77,7 @@
         <dependency>
             <groupId>org.eclipse.jetty</groupId>
             <artifactId>jetty-util</artifactId>
-            <version>9.4.14.v20181114</version>
+            <version>9.4.18.v20190429</version>
         </dependency>
 
         <dependency>

diff --git a/...t-confluent/src/main/java/fr/jetoile/hadoopunit/component/ConfluentKsqlRestBootstrap.java b/...t-confluent/src/main/java/fr/jetoile/hadoopunit/component/ConfluentKsqlRestBootstrap.java
@@ -100,8 +100,6 @@ private void build() {
             KsqlRestConfig config = new KsqlRestConfig(ksqlConfig);
             restServer = KsqlRestApplication.buildApplication(config, KsqlVersionCheckerAgent::new, Integer.MAX_VALUE);
             restServer.createServer();
-        } catch (RestConfigException e) {
-            LOGGER.error("Server configuration failed: ", e);
         } catch (Exception e) {
             LOGGER.error("Server died unexpectedly: ", e);
         }