removed zkclient

prestodb · Nov 27, 2024 · 2576948 · 2576948
1 parent 65ebf84
commit 2576948
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 10 deletions.
diff --git a/build.gradle b/build.gradle
@@ -57,8 +57,7 @@ ext.versions = [
         cassandra    : '3.4.0',
         commons_cli  : '1.3.1',
         thrift       : '0.9.3',
-        kafka        : '2.8.2',
-        zkclient     : '0.10'
+        kafka        : '2.8.2'
 ]
 
 ext.libraries = [
@@ -102,8 +101,7 @@ ext.libraries = [
         commons_cli          : "commons-cli:commons-cli:${versions.commons_cli}",
         thrift               : "org.apache.thrift:libthrift:${versions.thrift}",
         kafka_clients        : "org.apache.kafka:kafka-clients:${versions.kafka}",
-        kafka                : "org.apache.kafka:kafka_2.12:${versions.kafka}",
-        zkclient             : "com.101tec:zkclient:${versions.zkclient}"
+        kafka                : "org.apache.kafka:kafka_2.12:${versions.kafka}"
 ]
 
 ext.tempto_core = project(':tempto-core')

diff --git a/tempto-kafka/build.gradle b/tempto-kafka/build.gradle
@@ -17,7 +17,6 @@ apply plugin: 'java'
 dependencies {
     compile tempto_core
     compile libraries.kafka
-    compile libraries.zkclient
 }
 
 // project information

diff --git a/tempto-kafka/src/main/java/io/prestodb/tempto/fulfillment/table/kafka/KafkaTableManager.java b/tempto-kafka/src/main/java/io/prestodb/tempto/fulfillment/table/kafka/KafkaTableManager.java
@@ -127,11 +127,7 @@ private void createTopic(String topic, int partitionsCount, int replicationLevel
             try {
                 adminClient.createTopics(Collections.singletonList(newTopic)).all().get();
             } catch (ExecutionException | InterruptedException e) {
-                if (e.getCause() instanceof TopicExistsException) {
-                    // Topic already exists, no need to create
-                } else {
-                    throw new RuntimeException("Failed to create topic " + topic, e);
-                }
+                throw new RuntimeException("Failed to create topic " + topic, e);
             }
         });
     }