Merge pull request #558 from microsoft/dev

Release 1.14.1

Author: xinlian12

CHANGELOG.md

@@ -1,5 +1,9 @@
 ## Release History
 
+### 1.14.1 (2024-02-29)
+#### Key Bug Fixes
+* Fixed `NullPointerException` in `CosmosDBSourceConnector`. [PR 555](https://github.com/microsoft/kafka-connect-cosmosdb/pull/555)
+
 ### 1.14.0 (2024-02-28)
 #### New Features
 * Updated `azure-cosmos` version to 4.56.0.

pom.xml

@@ -7,7 +7,7 @@
 
     <groupId>com.azure.cosmos.kafka</groupId>
     <artifactId>kafka-connect-cosmos</artifactId>
-    <version>1.14.0</version>
+    <version>1.14.1</version>
 
     <name> kafka-connect-cosmos</name>
     <url>https://github.com/microsoft/kafka-connect-cosmosdb</url>

src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTask.java

@@ -63,8 +63,9 @@ public String version() {
 
     @Override
     public void start(Map<String, String> map) {
-        logger.info("Worker {} Starting CosmosDBSourceTask.", this.config.getWorkerName());
-        config = new CosmosDBSourceConfig(map);        
+        logger.info("Starting CosmosDBSourceTask.");
+        config = new CosmosDBSourceConfig(map);
+
         this.queue = new LinkedTransferQueue<>();
 
         logger.info("Worker {} Creating the client.", this.config.getWorkerName());

src/test/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTaskTest.java

@@ -9,6 +9,7 @@
 import static org.mockito.Mockito.when;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
@@ -96,6 +97,12 @@ public void setup() throws IllegalAccessException {
 
     }
 
+    @Test(expected = IllegalArgumentException.class)
+    public void start() {
+        CosmosDBSourceTask testTask = new CosmosDBSourceTask();
+        testTask.start(sourceSettings);
+    }
+
     @Test
     public void testHandleChanges() throws JsonProcessingException, IllegalAccessException, InterruptedException {
         String jsonString = "{\"k1\":\"v1\",\"k2\":\"v2\", \"_lsn\":\"2\"}";