commit ba8280fad3eed350462edfc3280446d08a63ca67
author Naburun Nag <nag@cs.wisc.edu> Mon Mar 02 17:49:04 2020 -0800
committer Naburun Nag <nag@cs.wisc.edu> Mon Mar 02 17:49:04 2020 -0800
tree 33fc2e0bc9b615c87a584c4e6f2614eae0939a67
parent 6f1a87e3ef0130906b1e9bdbe4f59912bc7a5477

Using ConnectException

src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java

diff --git a/src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java b/src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java
index dddb28b..48dcf30 100644
--- a/src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java
+++ b/src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java
@@ -20,6 +20,7 @@
 import java.util.Map;
 import java.util.stream.Collectors;
 
+import org.apache.kafka.connect.errors.ConnectException;
 import org.apache.kafka.connect.sink.SinkRecord;
 import org.apache.kafka.connect.sink.SinkTask;
 import org.slf4j.Logger;
@@ -66,8 +67,7 @@
           geodeConnectorConfig.usesSecurity());
       regionNameToRegion = createProxyRegions(topicToRegions.values());
     } catch (Exception e) {
-      logger.error("Unable to start sink task", e);
-      throw e;
+      throw new ConnectException("Unable to start sink task", e);
     }
   }