Fixing build warning

Author: FabianMeiswinkel

sdk/cosmos/azure-cosmos-encryption/src/test/java/com/azure/cosmos/encryption/TestSuiteBase.java

@@ -284,7 +284,7 @@ public void afterClassSetupLeakDetection() {
     }
 
     @BeforeSuite(groups = {"fast", "long", "direct", "multi-master", "encryption"}, timeOut = SUITE_SETUP_TIMEOUT)
-    public static void beforeSuite() {
+    public void beforeSuite() {
 
         logger.info("beforeSuite Started");
 
@@ -318,14 +318,14 @@ public static void beforeSuite() {
     }
 
     @BeforeSuite(groups = {"unit"})
-    public static void parallelizeUnitTests(ITestContext context) {
+    public void parallelizeUnitTests(ITestContext context) {
         // TODO: Parallelization was disabled due to flaky tests. Re-enable after fixing the flaky tests.
 //        context.getSuite().getXmlSuite().setParallel(XmlSuite.ParallelMode.CLASSES);
 //        context.getSuite().getXmlSuite().setThreadCount(Runtime.getRuntime().availableProcessors());
     }
 
     @AfterSuite(groups = {"fast", "long", "direct", "multi-master", "encryption"}, timeOut = SUITE_SHUTDOWN_TIMEOUT)
-    public static void afterSuite() {
+    public void afterSuite() {
 
         logger.info("afterSuite Started");
 

sdk/cosmos/azure-cosmos-kafka-connect/pom.xml

@@ -32,6 +32,11 @@ Licensed under the MIT License.
       <name>Confluent</name>
       <url>https://packages.confluent.io/maven/</url>
     </repository>
+    <repository>
+      <id>maven-repo1</id>
+      <name>Maven Repo1</name>
+      <url>https://repo1.maven.org/maven2/</url>
+    </repository>
   </repositories>
 
   <scm>

sdk/cosmos/azure-cosmos-kafka-connect/src/test/java/com/azure/cosmos/kafka/connect/KafkaCosmosIntegrationTestSuiteBase.java

@@ -39,15 +39,15 @@ public class KafkaCosmosIntegrationTestSuiteBase extends KafkaCosmosTestSuiteBas
     protected static KafkaCosmosConnectContainer kafkaCosmosConnectContainer;
 
     @BeforeSuite(groups = { "kafka-integration" }, timeOut = 10 * SUITE_SETUP_TIMEOUT)
-    public static void beforeIntegrationSuite() throws IOException, InterruptedException {
+    public void beforeIntegrationSuite() throws IOException, InterruptedException {
 
         logger.info("beforeIntegrationSuite Started");
         // initialize the kafka, kafka-connect containers
         setupDockerContainers();
     }
 
     @AfterSuite(groups = { "kafka-integration" }, timeOut = 10 * SUITE_SETUP_TIMEOUT)
-    public static void afterIntegrationSuite() {
+    public void afterIntegrationSuite() {
 
         logger.info("afterIntegrationSuite Started");
         // The TestContainers library will automatically clean up resources by using Ryuk sidecar container

sdk/cosmos/azure-cosmos-kafka-connect/src/test/java/com/azure/cosmos/kafka/connect/KafkaCosmosTestSuiteBase.java

@@ -90,7 +90,7 @@ protected static CosmosContainerProperties getSinglePartitionContainer(CosmosAsy
     }
 
     @BeforeSuite(groups = { "kafka", "kafka-integration" }, timeOut = SUITE_SETUP_TIMEOUT)
-    public static void beforeSuite() {
+    public void beforeSuite() {
 
         logger.info("beforeSuite Started");
         try (CosmosAsyncClient houseKeepingClient = createGatewayHouseKeepingDocumentClient(true).buildAsyncClient()) {
@@ -122,7 +122,7 @@ public static void beforeSuite() {
     }
 
     @BeforeSuite(groups = { "kafka-emulator" }, timeOut = SUITE_SETUP_TIMEOUT)
-    public static void beforeSuite_emulator() {
+    public void beforeSuite_emulator() {
 
         logger.info("beforeSuite Started");
         try (CosmosAsyncClient houseKeepingClient = createGatewayHouseKeepingDocumentClient(true).buildAsyncClient()) {
@@ -154,7 +154,7 @@ public static void beforeSuite_emulator() {
     }
 
     @BeforeSuite(groups = { "unit" }, timeOut = SUITE_SETUP_TIMEOUT)
-    public static void beforeSuite_unit() {
+    public void beforeSuite_unit() {
         logger.info("beforeSuite for unit tests started");
 
         databaseName =
@@ -166,7 +166,7 @@ public static void beforeSuite_unit() {
     }
 
     @AfterSuite(groups = { "kafka", "kafka-integration", "kafka-emulator" }, timeOut = SUITE_SHUTDOWN_TIMEOUT)
-    public static void afterSuite() {
+    public void afterSuite() {
 
         logger.info("afterSuite Started");
 

sdk/cosmos/azure-cosmos-tests/src/test/java/com/azure/cosmos/implementation/TestSuiteBase.java

@@ -204,7 +204,7 @@ public void afterClassSetupLeakDetection() {
 
     @BeforeSuite(groups = {"fast", "long", "direct", "multi-region", "multi-master", "flaky-multi-master", "emulator",
         "split", "query", "cfp-split", "long-emulator"}, timeOut = SUITE_SETUP_TIMEOUT)
-    public static void beforeSuite() {
+    public void beforeSuite() {
         logger.info("beforeSuite Started");
         AsyncDocumentClient houseKeepingClient = createGatewayHouseKeepingDocumentClient().build();
         try {
@@ -221,15 +221,15 @@ public static void beforeSuite() {
     }
 
     @BeforeSuite(groups = {"unit"})
-    public static void parallelizeUnitTests(ITestContext context) {
+    public void parallelizeUnitTests(ITestContext context) {
         // TODO: Parallelization was disabled due to flaky tests. Re-enable after fixing the flaky tests.
 //        context.getSuite().getXmlSuite().setParallel(XmlSuite.ParallelMode.CLASSES);
 //        context.getSuite().getXmlSuite().setThreadCount(Runtime.getRuntime().availableProcessors());
     }
 
     @AfterSuite(groups = {"fast", "long", "direct", "multi-region", "multi-master", "flaky-multi-master", "emulator",
         "split", "query", "cfp-split", "long-emulator"}, timeOut = SUITE_SHUTDOWN_TIMEOUT)
-    public static void afterSuite() {
+    public void afterSuite() {
         logger.info("afterSuite Started");
         AsyncDocumentClient houseKeepingClient = createGatewayHouseKeepingDocumentClient().build();
         try {

sdk/cosmos/azure-cosmos-tests/src/test/java/com/azure/cosmos/rx/TestSuiteBase.java

@@ -286,7 +286,7 @@ public void beforeSuite() {
     }
 
     @BeforeSuite(groups = {"unit"})
-    public static void parallelizeUnitTests(ITestContext context) {
+    public void parallelizeUnitTests(ITestContext context) {
         // TODO: Parallelization was disabled due to flaky tests. Re-enable after fixing the flaky tests.
 //        context.getSuite().getXmlSuite().setParallel(XmlSuite.ParallelMode.CLASSES);
 //        context.getSuite().getXmlSuite().setThreadCount(Runtime.getRuntime().availableProcessors());