fix : issue with binding

Author: rajadileepkolli

aws-kinesis-project/consumer/src/main/java/com/learning/aws/spring/consumer/IpConsumerKCLEnabled.java

@@ -13,8 +13,7 @@
 @Configuration(proxyBeanMethods = false)
 @ConditionalOnProperty(
         value = "spring.cloud.stream.kinesis.binder.kpl-kcl-enabled",
-        havingValue = "true",
-        matchIfMissing = false)
+        havingValue = "true")
 public class IpConsumerKCLEnabled {
 
     private static final Logger log = LoggerFactory.getLogger(IpConsumerKCLEnabled.class);

aws-kinesis-project/consumer/src/main/java/com/learning/aws/spring/consumer/IpConsumerWithOutKCL.java

@@ -14,8 +14,7 @@
 @Configuration(proxyBeanMethods = false)
 @ConditionalOnProperty(
         value = "spring.cloud.stream.kinesis.binder.kpl-kcl-enabled",
-        havingValue = "false",
-        matchIfMissing = false)
+        havingValue = "false")
 public class IpConsumerWithOutKCL {
 
     private static final Logger log = LoggerFactory.getLogger(IpConsumerWithOutKCL.class);

aws-kinesis-project/consumer/src/test/java/com/learning/aws/spring/ApplicationIntegrationTest.java

@@ -5,18 +5,16 @@
 
 import com.learning.aws.spring.common.AbstractIntegrationTest;
 import java.time.Duration;
-import java.util.concurrent.TimeUnit;
 import org.junit.jupiter.api.Test;
 
 class ApplicationIntegrationTest extends AbstractIntegrationTest {
 
     @Test
-    void contextLoads() throws InterruptedException {
-        // awaiting consumer to start processing
-        TimeUnit.SECONDS.sleep(3);
+    void contextLoads() {
         Long initialCount = ipAddressEventRepository.count().block();
         await().atMost(Duration.ofSeconds(30))
-                .pollDelay(Duration.ofSeconds(1))
+                .pollInterval(Duration.ofMillis(200))
+                .pollDelay(Duration.ofSeconds(3))
                 .untilAsserted(
                         () ->
                                 assertThat(ipAddressEventRepository.count().block() + initialCount)

aws-kinesis-project/consumer/src/test/java/com/learning/aws/spring/common/ContainersConfig.java

@@ -3,6 +3,7 @@
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
+import org.springframework.test.context.DynamicPropertyRegistrar;
 import org.testcontainers.localstack.LocalStackContainer;
 import org.testcontainers.postgresql.PostgreSQLContainer;
 import org.testcontainers.utility.DockerImageName;
@@ -22,4 +23,16 @@ LocalStackContainer localStackContainer() {
     PostgreSQLContainer postgreSQLContainer() {
         return new PostgreSQLContainer(DockerImageName.parse("postgres:18.1-alpine"));
     }
+
+    @Bean
+    DynamicPropertyRegistrar dynamicPropertyRegistrar(LocalStackContainer localStackContainer) {
+        return registry -> {
+            registry.add("spring.cloud.aws.endpoint", localStackContainer::getEndpoint);
+            registry.add("spring.cloud.aws.region.static", localStackContainer::getRegion);
+            registry.add(
+                    "spring.cloud.aws.credentials.access-key", localStackContainer::getAccessKey);
+            registry.add(
+                    "spring.cloud.aws.credentials.secret-key", localStackContainer::getSecretKey);
+        };
+    }
 }

aws-kinesis-project/producer/src/test/java/com/learning/aws/spring/common/ContainerConfig.java

@@ -4,6 +4,7 @@
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
+import org.springframework.test.context.DynamicPropertyRegistrar;
 import org.testcontainers.localstack.LocalStackContainer;
 import org.testcontainers.utility.DockerImageName;
 import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
@@ -44,4 +45,16 @@ KinesisAsyncClient amazonKinesis(LocalStackContainer localStackContainer) {
                                 .build())
                 .build();
     }
+
+    @Bean
+    DynamicPropertyRegistrar dynamicPropertyRegistrar(LocalStackContainer localStackContainer) {
+        return registry -> {
+            registry.add("spring.cloud.aws.endpoint", localStackContainer::getEndpoint);
+            registry.add("spring.cloud.aws.region.static", localStackContainer::getRegion);
+            registry.add(
+                    "spring.cloud.aws.credentials.access-key", localStackContainer::getAccessKey);
+            registry.add(
+                    "spring.cloud.aws.credentials.secret-key", localStackContainer::getSecretKey);
+        };
+    }
 }