From 9e3e35acf94ae92c0091a8d882521d4cf04d13bd Mon Sep 17 00:00:00 2001 From: Ohad Bitton Date: Mon, 15 Jun 2020 22:16:19 +0300 Subject: [PATCH] shouldnt hide appId --- .../kusto/kafka/connect/sink/KustoSinkConfig.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java b/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java index c72ef7f..6e7db70 100644 --- a/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java +++ b/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java @@ -170,7 +170,7 @@ public class KustoSinkConfig extends AbstractConfig { KUSTO_AUTH_APPKEY_DISPLAY) .define( KUSTO_AUTH_APPID_CONF, - Type.PASSWORD, + Type.STRING, null, Importance.HIGH, KUSTO_AUTH_APPID_DOC, @@ -180,7 +180,7 @@ public class KustoSinkConfig extends AbstractConfig { KUSTO_AUTH_APPID_DISPLAY) .define( KUSTO_AUTH_AUTHORITY_CONF, - Type.PASSWORD, + Type.STRING, null, Importance.HIGH, KUSTO_AUTH_AUTHORITY_DOC, @@ -292,11 +292,11 @@ public class KustoSinkConfig extends AbstractConfig { } public String getAuthPassword() { - return this.getString(KUSTO_AUTH_PASSWORD_CONF); + return this.getPassword(KUSTO_AUTH_PASSWORD_CONF).value(); } public String getKustoAuthAppid() { - return this.getPassword(KUSTO_AUTH_APPID_CONF).value(); + return KUSTO_AUTH_APPID_CONF; } public String getAuthAppkey() { @@ -304,7 +304,7 @@ public class KustoSinkConfig extends AbstractConfig { } public String getAuthAuthority() { - return this.getPassword(KUSTO_AUTH_AUTHORITY_CONF).value(); + return KUSTO_AUTH_AUTHORITY_CONF; } public String getTopicToTableMapping() {