AYS-508 | Kinesis Integration & Removed DynamoDB Integration (#401)

pom.xml

@@ -204,13 +204,7 @@
 
         <dependency>
             <groupId>software.amazon.awssdk</groupId>
-            <artifactId>dynamodb</artifactId>
-            <version>${awsjavasdk.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>software.amazon.awssdk</groupId>
-            <artifactId>dynamodb-enhanced</artifactId>
+            <artifactId>kinesis</artifactId>
             <version>${awsjavasdk.version}</version>
         </dependency>
         <!-- ===================== -->

src/main/java/org/ays/common/config/AysKinesisConfiguration.java

@@ -0,0 +1,34 @@
+package org.ays.common.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
+import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.kinesis.KinesisClient;
+
+@Configuration
+@Profile("kinesis")
+public class AysKinesisConfiguration {
+
+    @Value("${aws.credentials.access-key-id}")
+    private String accessKey;
+
+    @Value("${aws.credentials.secret-access-key}")
+    private String secretKey;
+
+    @Value("${aws.kinesis.region}")
+    private String region;
+
+    @Bean
+    public KinesisClient kinesisClient() {
+        AwsBasicCredentials awsCredentials = AwsBasicCredentials.create(accessKey, secretKey);
+
+        return KinesisClient.builder()
+                .credentialsProvider(StaticCredentialsProvider.create(awsCredentials))
+                .region(Region.of(region))
+                .build();
+    }
+}

src/main/resources/application-kinesis.yml

@@ -0,0 +1,6 @@
+aws:
+  kinesis:
+    region: ${AWS_KINESIS_REGION:}
+  credentials:
+    access-key-id: ${AWS_KINESIS_ACCESS_KEY_ID:}
+    secret-access-key: ${AWS_KINESIS_SECRET_ACCESS_KEY:}