[geode-kafka-connector] branch master updated: Using ConnectException

[nn...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

nnag pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/geode-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new ba8280f  Using ConnectException
ba8280f is described below

commit ba8280fad3eed350462edfc3280446d08a63ca67
Author: Naburun Nag <na...@cs.wisc.edu>
AuthorDate: Mon Mar 2 17:49:04 2020 -0800

    Using ConnectException
---
 src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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.List;
 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 @@ public class GeodeKafkaSinkTask extends SinkTask {
           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);
     }
   }