Merge pull request #160 from siddhi-io/revert-159-master

Revert "Add error log when KafkaConsumerThread terminate unexpectedly"
siddhi-io · Mar 2, 2023 · 6daaef5 · 6daaef5
2 parents 8eb2d4a + 761cbb2
commit 6daaef5
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/component/src/main/java/io/siddhi/extension/io/kafka/source/ConsumerKafkaGroup.java b/component/src/main/java/io/siddhi/extension/io/kafka/source/ConsumerKafkaGroup.java
@@ -27,7 +27,6 @@
 import java.util.Arrays;
 import java.util.List;
 import java.util.Properties;
-import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Future;
 
@@ -116,14 +115,6 @@ void run() {
         try {
             for (KafkaConsumerThread consumerThread : kafkaConsumerThreadList) {
                 futureList.add(executorService.submit(consumerThread));
-                futureList.add(CompletableFuture.runAsync(consumerThread, executorService).whenComplete(
-                        (ignored, throwable) -> {
-                            if (throwable != null) {
-                                LOG.error("KafkaConsumerThread for topic(s):{} terminated unexpectedly!",
-                                        Arrays.toString(topics), throwable);
-                            }
-                        }
-                ));
             }
         } catch (Throwable t) {
             LOG.error("Error while creating KafkaConsumerThread for topic(s): " + Arrays.toString(topics), t);