Handle NPE in getKeyfile()

wepay · Feb 4, 2020 · b20c03f · b20c03f
1 parent 2f93dd2
commit b20c03f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java
@@ -28,6 +28,7 @@
 import com.wepay.kafka.connect.bigquery.convert.SchemaConverter;
 
 import org.apache.kafka.common.config.AbstractConfig;
+import org.apache.kafka.common.config.types.Password;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigException;
 
@@ -410,7 +411,7 @@ protected static Map.Entry<String, String> parseMapping(String mapping, String n
    * Returns the keyfile
    */
   public String getKeyFile() {
-    return getPassword(KEYFILE_CONFIG).value();
+    return Optional.ofNullable(getPassword(KEYFILE_CONFIG)).map(Password::value).orElse(null);
   }
 
   /**