DBZ-9439- Added integeration tests.

Signed-off-by: pranavt84 <[email protected]>

Author: pranavt84

…tination/KinesisConnectionValidator.java …on/AmazonKinesisConnectionValidator.javadebezium-platform-conductor/src/main/java/io/debezium/platform/environment/connection/destination/KinesisConnectionValidator.java renamed to debezium-platform-conductor/src/main/java/io/debezium/platform/environment/connection/destination/AmazonKinesisConnectionValidator.java debezium-platform-conductor/src/main/java/io/debezium/platform/environment/connection/destination/KinesisConnectionValidator.java renamed to debezium-platform-conductor/src/main/java/io/debezium/platform/environment/connection/destination/AmazonKinesisConnectionValidator.java

@@ -31,9 +31,9 @@
  */
 @ApplicationScoped
 @Named("AMAZON_KINESIS")
-public class KinesisConnectionValidator implements ConnectionValidator {
+public class AmazonKinesisConnectionValidator implements ConnectionValidator {
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(KinesisConnectionValidator.class);
+    private static final Logger LOGGER = LoggerFactory.getLogger(AmazonKinesisConnectionValidator.class);
 
     private static final String REGION_KEY = "region";
     private static final String STREAM_NAME_KEY = "stream";
@@ -43,8 +43,8 @@ public class KinesisConnectionValidator implements ConnectionValidator {
 
     private final int defaultTimeout;
 
-    public KinesisConnectionValidator(
-                                      @ConfigProperty(name = "destinations.kinesis.connection.timeout") int defaultTimeout) {
+    public AmazonKinesisConnectionValidator(
+                                            @ConfigProperty(name = "destinations.kinesis.connection.timeout") int defaultTimeout) {
         this.defaultTimeout = defaultTimeout;
     }
 

…ection/KinesisConnectionValidatorIT.java …/AmazonKinesisConnectionValidatorIT.javadebezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/KinesisConnectionValidatorIT.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/AmazonKinesisConnectionValidatorIT.java debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/KinesisConnectionValidatorIT.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/AmazonKinesisConnectionValidatorIT.java

@@ -21,23 +21,23 @@
 import io.debezium.platform.data.dto.ConnectionValidationResult;
 import io.debezium.platform.data.model.ConnectionEntity;
 import io.debezium.platform.domain.views.Connection;
-import io.debezium.platform.environment.connection.destination.KinesisConnectionValidator;
-import io.debezium.platform.environment.database.db.KinesisTestResource;
+import io.debezium.platform.environment.connection.destination.AmazonKinesisConnectionValidator;
+import io.debezium.platform.environment.database.db.AmazonKinesisTestResource;
 import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
 
 /**
- * Integration tests for {@link KinesisConnectionValidator}.
+ * Integration tests for {@link AmazonKinesisConnectionValidator}.
  * Tests the validator against a real LocalStack container running Kinesis.
  *
  * @author Pranav Tiwari
  */
 @QuarkusTest
-@QuarkusTestResource(KinesisTestResource.class)
-public class KinesisConnectionValidatorIT {
+@QuarkusTestResource(AmazonKinesisTestResource.class)
+public class AmazonKinesisConnectionValidatorIT {
 
     @Inject
-    KinesisConnectionValidator validator;
+    AmazonKinesisConnectionValidator validator;
 
     // ==================== SUCCESSFUL CONNECTION TESTS ====================
 

…tion/KinesisConnectionValidatorTest.java …mazonKinesisConnectionValidatorTest.javadebezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/KinesisConnectionValidatorTest.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/AmazonKinesisConnectionValidatorTest.java debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/KinesisConnectionValidatorTest.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/connection/AmazonKinesisConnectionValidatorTest.java

@@ -20,22 +20,22 @@
 import io.debezium.platform.data.dto.ConnectionValidationResult;
 import io.debezium.platform.data.model.ConnectionEntity;
 import io.debezium.platform.domain.views.Connection;
-import io.debezium.platform.environment.connection.destination.KinesisConnectionValidator;
+import io.debezium.platform.environment.connection.destination.AmazonKinesisConnectionValidator;
 
 /**
- * Unit tests for {@link KinesisConnectionValidator}.
+ * Unit tests for {@link AmazonKinesisConnectionValidator}.
  * Tests configuration validation logic without actual AWS connectivity.
  *
  * @author Pranav Tiwari
  */
-class KinesisConnectionValidatorTest {
+class AmazonKinesisConnectionValidatorTest {
 
     private static final int DEFAULT_TIMEOUT = 30;
-    private KinesisConnectionValidator validator;
+    private AmazonKinesisConnectionValidator validator;
 
     @BeforeEach
     void setUp() {
-        validator = new KinesisConnectionValidator(DEFAULT_TIMEOUT);
+        validator = new AmazonKinesisConnectionValidator(DEFAULT_TIMEOUT);
     }
 
     // ==================== NULL AND EMPTY CONFIGURATION TESTS ====================

…ent/database/db/KinesisTestResource.java …tabase/db/AmazonKinesisTestResource.javadebezium-platform-conductor/src/test/java/io/debezium/platform/environment/database/db/KinesisTestResource.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/database/db/AmazonKinesisTestResource.java debezium-platform-conductor/src/test/java/io/debezium/platform/environment/database/db/KinesisTestResource.java renamed to debezium-platform-conductor/src/test/java/io/debezium/platform/environment/database/db/AmazonKinesisTestResource.java

@@ -68,7 +68,7 @@
  *
  * @author Pranav Kumar Tiwari
  */
-public class KinesisTestResource implements QuarkusTestResourceLifecycleManager {
+public class AmazonKinesisTestResource implements QuarkusTestResourceLifecycleManager {
 
     private LocalStackContainer localStack;
     private final String streamName = "test-stream";