From b20c03fd010da3c4c60e0a5e309a04aec695e584 Mon Sep 17 00:00:00 2001 From: Ilanji Rajamanickam Date: Mon, 3 Feb 2020 16:17:24 -0800 Subject: [PATCH] Handle NPE in getKeyfile() --- .../kafka/connect/bigquery/config/BigQuerySinkConfig.java | 3 ++- 1 file changed, 2 insertions(+), 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 index 0268b5c3e..7d4cf0f22 100644 --- 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 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); } /**