From 8be3ede95f3549bf7a9251dfbf5a866fbde0bd3c Mon Sep 17 00:00:00 2001 From: Annie Liang <64233642+xinlian12@users.noreply.github.com> Date: Thu, 29 Feb 2024 08:51:15 -0800 Subject: [PATCH] Update CosmosDBSourceTaskTest.java --- .../kafka/connect/source/CosmosDBSourceTaskTest.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/src/test/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTaskTest.java b/src/test/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTaskTest.java index 90020b72..9b553634 100644 --- a/src/test/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTaskTest.java +++ b/src/test/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceTaskTest.java @@ -32,8 +32,6 @@ import org.mockito.Mockito; public class CosmosDBSourceTaskTest { - private final static String COSMOS_EMULATOR_KEY = "C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw=="; - private final static String COSMOS_EMULATOR_HOST = "https://localhost:8081/"; private CosmosDBSourceTask testTask; private final String topicName = "testtopic"; private final String containerName = "container666"; @@ -102,11 +100,6 @@ public void setup() throws IllegalAccessException { @Test(expected = IllegalArgumentException.class) public void start() { CosmosDBSourceTask testTask = new CosmosDBSourceTask(); - HashMap configs = new HashMap<>(); - configs.put(CosmosDBSourceConfig.COSMOS_CONN_ENDPOINT_CONF, COSMOS_EMULATOR_HOST); - configs.put(CosmosDBSourceConfig.COSMOS_CONN_KEY_CONF, COSMOS_EMULATOR_KEY); - configs.put(CosmosDBSourceConfig.COSMOS_DATABASE_NAME_CONF, "mydb"); - configs.put(CosmosDBSourceConfig.COSMOS_CONTAINER_TOPIC_MAP_CONF, "mytopic5#mycontainer6"); testTask.start(sourceSettings); }