Merge branch 'master' into addOptionalEngineUrlConfig

README.md

@@ -219,7 +219,7 @@ The following is complete set of connector sink properties-
 | :--- | :--- | :--- | :--- | 
 | 1 | connector.class | Classname of the Kusto sink | Hard code to ``` com.microsoft.azure.kusto.kafka.connect.sink.KustoSinkConnector ```<br>*Required* |
 | 2 | topics | Kafka topic specification | List of topics separated by commas<br>*Required*  |
-| 3 | kusto.url | Kusto ingest node specification | Provide the ingest URI of your ADX cluster<br>*Required*  |
+| 3 | kusto.url | Kusto ingest cluster specification | Provide the ingest URI of your ADX cluster<br>Use the following construct for the private URL - https://ingest-private-[cluster].kusto.windows.net<br>*Required*  |
 | 4 | kusto.engine.url | Kusto engine node specification | Provide the engine URI of your ADX cluster<br>*Optional*  |
 | 5 | aad.auth.authority | Credentials for Kusto | Provide the tenant ID of your Azure Active Directory<br>*Required*  |
 | 6 | aad.auth.appid | Credentials for Kusto  | Provide Azure Active Directory Service Principal Name<br>*Required*  |

pom.xml

@@ -9,7 +9,7 @@
     <artifactId>kafka-sink-azure-kusto</artifactId>
     <packaging>jar</packaging>
     <description>A Kafka Connect plugin for Azure Data Explorer (Kusto) Database</description>
-    <version>1.0.1</version>
+    <version>1.0.2</version>
     <properties>
         <kafka.version>1.0.0</kafka.version>
         <json.version>20090211</json.version>

src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkTask.java

@@ -243,7 +243,7 @@ public class KustoSinkTask extends SinkTask {
         try {
             try {
                 KustoOperationResult rs = engineClient.execute(database, String.format(FETCH_TABLE_QUERY, table));
-                if ((int) rs.getPrimaryResults().getData().get(0).get(0) >= 0) {
+                if ((long) rs.getPrimaryResults().getData().get(0).get(0) >= 0) {
                     hasAccess = true;
                 }