From bcebb4c33e4b7df95bb4ec3ddd8ffe5ceb6ac637 Mon Sep 17 00:00:00 2001
From: naveenkantamneni <navi.k19@gmail.com>
Date: Tue, 15 Aug 2023 16:48:19 -0700
Subject: [PATCH] Added example java Application with steps to connect to
 Amazon Keyspaces from Amazon EKS using SigV4 Authentication

---
 .../connection-EKS-SigV4/.DS_Store            | Bin 0 -> 6148 bytes
 .../connection-EKS-SigV4/Dockerfile           |  27 +++++
 .../connection-EKS-SigV4/README.md            |  98 ++++++++++++++++++
 .../cassandra_truststore.jks                  | Bin 0 -> 1430 bytes
 .../connection-EKS-SigV4/deployment.yaml      |  33 ++++++
 java/datastax-v4/connection-EKS-SigV4/pom.xml |  76 ++++++++++++++
 .../connection-EKS-SigV4/src/.DS_Store        | Bin 0 -> 6148 bytes
 .../connection-EKS-SigV4/src/main/.DS_Store   | Bin 0 -> 8196 bytes
 ...eyspacessigv4springbootappApplication.java |  73 +++++++++++++
 .../src/main/resources/application.conf       |  17 +++
 .../src/main/resources/logback.xml            |  13 +++
 ...cessigv4springbootappApplicationTests.java |  13 +++
 12 files changed, 350 insertions(+)
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/.DS_Store
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/Dockerfile
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/README.md
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/cassandra_truststore.jks
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/deployment.yaml
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/pom.xml
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/.DS_Store
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/main/.DS_Store
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/main/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplication.java
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/main/resources/application.conf
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/main/resources/logback.xml
 create mode 100644 java/datastax-v4/connection-EKS-SigV4/src/test/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplicationTests.java

diff --git a/java/datastax-v4/connection-EKS-SigV4/.DS_Store b/java/datastax-v4/connection-EKS-SigV4/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..5008ddfcf53c02e82d7eee2e57c38e5672ef89f6
GIT binary patch
literal 6148
zcmeH~Jr2S!425mzP>H1@V-^m;4Wg<&0T*E43hX&L&p$$qDprKhvt+--jT7}7np#A3
zem<@ulZcFPQ@L2!n>{z**<q8>++&mCkOWA81W14cNZ<zv;LbK1Poaz?KmsK2CSc!(
z0ynLxE!0092;Krf2c+FF_Fe*7ECH>lEfg7;MkzE(HCqgga^y>{tEnwC%0;vJ&^%eQ
zLs35+`xjp>T0<F0fCPF1$Cyrb|F7^5{eNG?83~ZUUlGt@xh*qZDeu<Z%US-OSsOPv
j)R!Z4KLME7ReXlK;d!wEw5GODWMKRea10D2@KpjYNUI8I

literal 0
HcmV?d00001

diff --git a/java/datastax-v4/connection-EKS-SigV4/Dockerfile b/java/datastax-v4/connection-EKS-SigV4/Dockerfile
new file mode 100644
index 0000000..e73cff4
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/Dockerfile
@@ -0,0 +1,27 @@
+# Start with a base image containing Java runtime
+FROM --platform=linux/amd64 openjdk:17-jdk-alpine
+
+# Make port 8080 available to the world outside this container
+EXPOSE 8080
+
+# Add a volume pointing to /tmp
+VOLUME /tmp
+
+# The application's jar file
+ARG JAR_FILE=target/mykeyspacessigv4springbootapp-1.0-SNAPSHOT.jar
+
+# Add the application's jar to the container
+COPY ${JAR_FILE} app.jar
+
+# Add the truststore to the container
+COPY cassandra_truststore.jks /usr/app/cassandra_truststore.jks
+
+# Add the application's properties to the container
+COPY src/main/resources/application.conf /usr/app/application.conf
+
+# Add the application's logback configuration to the container
+COPY src/main/resources/logback.xml /usr/app/logback.xml
+
+# Run the jar file
+ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app.jar"]
+
diff --git a/java/datastax-v4/connection-EKS-SigV4/README.md b/java/datastax-v4/connection-EKS-SigV4/README.md
new file mode 100644
index 0000000..2b5a87c
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/README.md
@@ -0,0 +1,98 @@
+# Connection to Amazon Keyspaces from Amazon EKS using SigV4 Authentication
+
+This example demonstrates how to connect to Amazon Keyspaces from an Amazon EKS cluster using SigV4 authentication.
+
+## Prerequisites
+
+- Amazon EKS cluster
+- Amazon Keyspaces
+- AWS CLI
+- kubectl
+- Docker
+- Amazon ECR
+
+## Setup
+
+### Clone the Repository
+
+```shell
+git clone https://github.com/naveenkantamneni/amazon-keyspaces-examples.git
+```
+
+## Create Keyspace and Table in Amazon Keyspaces
+
+```
+CREATE KEYSPACE aws WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '3'}  AND durable_writes = true;
+CREATE TABLE aws.user (
+    username text PRIMARY KEY,
+    fname text,
+    last_update_date timestamp,
+    lname text
+);
+```
+
+## Create your Amazon EKS Cluster by following steps in below page
+https://docs.aws.amazon.com/eks/latest/userguide/getting-started-eksctl.html
+
+## Create an OIDC provider for your EKS cluster by following instructions on below page
+https://docs.aws.amazon.com/eks/latest/userguide/enable-iam-roles-for-service-accounts.html
+
+## Create a Kubernetes Service Account to assume an IAM role by following the instructions on below page. Follow Instructions under AWS CLI section and make sure to add IAM Policy "AmazonKeyspacesFullAccess" to your IAM Role in step "g"
+https://docs.aws.amazon.com/eks/latest/userguide/associate-service-account-role.html
+
+## Confirm that the "AmazonKeyspacesFullAccess" policy that you attached to your role in a previous step is attached to the role.
+
+```
+aws iam list-attached-role-policies --role-name myeks-servicerole-assumewebid
+```
+
+An example output is as follows
+
+```
+{
+    "AttachedPolicies": [
+        {
+            "PolicyName": "AmazonKeyspacesFullAccess",
+            "PolicyArn": "arn:aws:iam::aws:policy/AmazonKeyspacesFullAccess"
+        }
+    ]
+}
+```
+
+## Create your Amazon ECR repository
+```
+aws ecr create-repository --repository-name <my repository>
+```
+
+## Navigate to the base Directory, Modify the Dockerfile as needed and build the Docker Image. Make sure to use your AWS Account ID, AWS Region where ECR repository created, ECR repository name and your tag during build
+
+```
+cd amazon-keyspaces-examples/java/datastax-v4/connection-EKS-SigV4
+docker build -t <aws_account_id>.dkr.ecr.<AWS_region>.amazonaws.com/<ECR_repositoryname>:<your_tag> .
+```
+
+## Retrieve Authentication Token to push the image to ECR
+```
+aws ecr get-login-password --region <AWS_region> | docker login --username AWS --password-stdin <aws_account_id>.dkr.ecr.<AWS_region>.amazonaws.com
+```
+
+## Push Docker Image to Amazon ECR repository
+```
+docker push <aws_account_id>.dkr.ecr.<AWS_region>.amazonaws.com/<ECR_repositoryname>:<your_tag>
+```
+
+## Modify deployment.yaml with relevant information and Deploy Application to Amazon EKS
+```
+kubectl apply -f deployment.yaml
+```
+
+## Check the POD status
+```
+kubectl get pods -n <your namespace>
+```
+
+### Optional, Validate Logs to ensure connectivity to Amazon Keyspaces
+```
+kubectl logs -f <POD_name> -n <your namespace>
+```
+
diff --git a/java/datastax-v4/connection-EKS-SigV4/cassandra_truststore.jks b/java/datastax-v4/connection-EKS-SigV4/cassandra_truststore.jks
new file mode 100644
index 0000000000000000000000000000000000000000..ce4b9face2fabcb68c122fb45712aee40afa07c9
GIT binary patch
literal 1430
zcmV;H1!?*)f(4QS0Ru3C1v~}`Duzgg_YDCD0ic2fEd+uEDKLTsB`|^oAqEL5hDe6@
z4FLxRpn?SwFoFdR0s#Opf&~W#2`Yw2hW8Bt2LUi<1_>&LNQU<f0R;^(Sui*T2`Yw2
zhW8Bt1q?7N1QZg@mo>RVU7LM^KFe=tqh@g$Au9p`ClCSwATSID2r7n1hW8Bu2?YQ!
z9R>+thDZTr0|Wso1Q3z`H|9WCV*i!OB%F!?R_cI)1dxD|6V)*@2+iM$aYzJ#W<DOd
z?Ih&~sQ_KlmvDvqIdKDB-v>qV^QiUoKpS@yOTbN?3XQk@e={AM%5l}3tsu;{+BuaP
zK9Rvjqu1+<odFjWjYjZb`RjrwNFWM>EYxWtz~5zL(HgDCYVI}+WhD}J`CGP6`(F#<
zKEdeNIu>$rPENV%E0ju0R?yf`Z9sOFd)mCb<Pp9W$X{#7jdYF|Q^<jUcU*sS(<tpc
zbIOiXAy76G!;fQElYOr#JrNJDjY;=t@LPD}{e>`8J;RKf`RRNh5n?Z_o?v|SOfhrA
zt_Z_y!<R#?z`6-ojT3?K`DbOV0B8miU?z+&yHsk<`nO6vE#g6RFBxq4EtE+4-;T-=
zJYa9FOxy_l(16t$<ybRabL<XPwa>jw@Z%~~C}Q2mnNN9XtZQZZL+OR=!^)jz@V4PT
z?5K##8nQe3G-jb%Y&yr<P=G^H0me3sJgr1uhvbgNG8<O`palclD!3}t2Y#kO%qpPj
zTG`{}d9i#fe#Q#%ZPuL({TP_0@DWIgneslU%c_X!F=_U*F>)G6n<0O*U4Nu1g9GyX
zb}L2cIbar0G>$Z)=%Vr~2B&p!S^T;~9$^%0g+B;J@Hzp)I1v>b^ea;y$(0ITaAu`v
zMpHzCC?7J&M|hx6B^K$^z(A#<zoQD!IXZObYR`Sj;$33DZ^72E(U7mk@p+|yA#o89
zQJl@Exh}{r=?CsjOnDR*>d*_Y9mz>hLfu1PWW3z2vk?TApxIk-Z5VL+hxveTE3d<E
zU5}(pxbzt>`ky3+nXz#use$1);Ki$G?TMv$+9joTR95*_7J9ndigr6ejRxw1nfQT5
zAxzuGUL{^sW?|4m6y91F40BfgsQ{8~$DN#g#x+{v;cVQ$y=j+r)dznBFd@XgyA9ho
z<Lgl;9|7KzP`FM`r*jN}s9-F3=JrJzcTveKRmJ$Rn%fM!TVo2i;inwLgK*?_0MX0y
zhC!YTx4yDOLr>@L8X5Wlm2iI~-CKSmw&C0p8Q-i~Ra?}ZBva_h;%kFXgCO!Ydq?ci
zI!PuH9Ue3;7JPm#mr$ELz-<&U%2dh`uYpsX7W&Uf0@`%%n*CW;d+@F7J`1};b<s#N
zIL{a?IehfsLOTK%?BL&9`&y7f#gsr}J$0KLEJ_jx^`TRXkktGtDlmRj;;j+eHd`4P
zsG#7z?N8)jyb+7onjQ7m2v8%+y%soNUu~2TIP<Y^tc``oo5K_F`h16xL)&Bd{pS3l
zT>u7p_t8B~x-rEUP;xU8PCA)u3fMoBpla7^5C}w?SxJl_vL)Jet(HyWkY~dFcqxB}
zATAv685#5~B?#GQNoGflmotFfP@gQHFLeLLsTDMaUVu1R@;iZ0)Y5Epj)DjLiBuc1
z-FYO~O->8q1dd0K2-iy`j8|8*s&H<IgsGI4szsm~Ju4nzr`>5pBkpuo`eL|zC${qe
zY=8;#UGhRML=aHJJ=XY2l9Yyz1oHM<c4B<dw2fS1lU14H;D1dOXTn^;HJ?ot<CCD_
z#eT0QcvUb>FflL<1_@w>NC9O71OfpC00bZ@Q%g1IpP0I6JEXmCp){ntj6iek3{AWt
k0oEZBA6e)G6yNeD#V`y^cbDvv$8?i>Mvx|ML;?aQ5VyaAS^xk5

literal 0
HcmV?d00001

diff --git a/java/datastax-v4/connection-EKS-SigV4/deployment.yaml b/java/datastax-v4/connection-EKS-SigV4/deployment.yaml
new file mode 100644
index 0000000..500c675
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/deployment.yaml
@@ -0,0 +1,33 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: mykeyspacessigv4springbootapp
+  namespace: <EKS namespace>
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: mykeyspacessigv4springbootapp
+  template:
+    metadata:
+      labels:
+        app: mykeyspacessigv4springbootapp
+    spec:
+      serviceAccountName: <eks-service-account>
+      containers:
+      - name: <ECR Repository name>
+        image: <aws_account_id>.dkr.ecr.<AWS_region>.amazonaws.com/<ECR_repositoryname>:<your_tag>
+        ports:
+        - containerPort: 8080
+        env:
+        - name: CASSANDRA_HOST
+          value: "<Keyspaces Endpoint>:9142"
+        - name: CASSANDRA_DC
+          value: "<keyspaces AWS region>"
+        - name: AWS_WEB_IDENTITY_TOKEN_FILE
+          value: /var/run/secrets/eks.amazonaws.com/serviceaccount/token
+        - name: AWS_ROLE_ARN
+          value: "arn:aws:iam::<AWS Account ID>:role/<IAM Role>"
+        - name: AWS_REGION
+          value: "<AWS Region>"
+
diff --git a/java/datastax-v4/connection-EKS-SigV4/pom.xml b/java/datastax-v4/connection-EKS-SigV4/pom.xml
new file mode 100644
index 0000000..67f9c1c
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/pom.xml
@@ -0,0 +1,76 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>3.1.1</version>
+		<relativePath/>
+	</parent>
+	<groupId>com.example</groupId>
+	<artifactId>mykeyspacessigv4springbootapp</artifactId>
+	<version>1.0-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>17</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>com.datastax.oss</groupId>
+			<artifactId>java-driver-core</artifactId>
+			<version>4.15.0</version>
+		</dependency>
+		<dependency>
+			<groupId>software.aws.mcs</groupId>
+			<artifactId>aws-sigv4-auth-cassandra-java-driver-plugin</artifactId>
+			<version>4.0.3</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+			<version>2.0.5</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-cassandra</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>javax.annotation</groupId>
+			<artifactId>javax.annotation-api</artifactId>
+			<version>1.3.2</version>
+		</dependency>
+		<dependency>
+			<groupId>com.amazonaws</groupId>
+			<artifactId>aws-java-sdk-sts</artifactId>
+			<version>1.11.717</version> <!-- Match this version to your aws-java-sdk version -->
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>3.8.0</version>
+				<configuration>
+					<release>17</release>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+</project>
diff --git a/java/datastax-v4/connection-EKS-SigV4/src/.DS_Store b/java/datastax-v4/connection-EKS-SigV4/src/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..5ea7480e13a9d5afa9a7d62dc5d97d44f28c1774
GIT binary patch
literal 6148
zcmeHK%}T>S5Z-O0O({YS3Oz1(Em+f15HBIt7cim+m70*E!8BW%)E-J9XMG``#OHBl
zcOw?-Rm9G~?l-@?*$=Wmj4|%d<737g#+VHak)yIf(7iEKGs%b?$A}jBG)iRz_M3_Q
zb--`8*o1{FVcFO3kEUso7v1hVuhp%c-G<$;TlQV>C>KEy7W3Q>XE$hFN|{EL9!6Km
zcrkMJ&tz7FNj9FTf+QY8%I$TM#d6`xc^2oYHqZgPX*Wksd%1LbZbuCI?y4h}CvLYR
z`n|zw)wB-|k4`T}Pw6C+FPcyed@I>ASivhOpX+%JW?3q;2k=$-RURQRKnxHA#K874
zV9o@)wY?P3%83DD;0Fe9e-O|RJ%go2wRJ#;*Jq4dh$x`rTLMuS^bD37Ap*j6DWERp
z=83^|IrxRi^9+_6bvff|W*EoJTs>a6njQQ?r8Dknq@EZc2G$v<YtzB={~UgqjgS2G
z60(Q^V&I=Kz^!30^kGrvZ2h)8JZlBCduS+_SE2#}`r0J`4BSWBDyZWEb;$D!mKt#s
S^s90}x(Fyjs3Qh`fq@TnhDt*K

literal 0
HcmV?d00001

diff --git a/java/datastax-v4/connection-EKS-SigV4/src/main/.DS_Store b/java/datastax-v4/connection-EKS-SigV4/src/main/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..d4cbeccefc297001db652ffe7fb18726ada45166
GIT binary patch
literal 8196
zcmeHMU2GIp6h3EK=$$D))6$mWWa&b|U@5R}E6AU0e*lqUYyVq*mf4+=j!b9D&g?Ew
zYx+cpU^G#Q@#j$uYIrcwV4{gpV|*|%5+tCBFZy7Nj~ZW0^xV0#4V0D#AN&b(leuTk
zJ?GrnbMANUoihsn*q%4;2dD=CMi-}QC3SN&F6Y;6O$tZKi6Yqp<RJ%HFu}_dZ_|zj
zq6kD0h$0Y0Ac{Z~f&W4T=*;Gg&2#PxY1Bs%h$3)TMu6`Rak@B7g>+ibVC$eRC;^D_
z5+G=FPjx_G6Ax)Bq|<^1rZlIh9xyb;u*5)NPVzWcCz=ZBw4lNqP?!UTPsXr9!Qkm+
z7Z20{Q-Vf)6oDuLw?}}dk4#lN)$HKjT)%r08QaZ}^m1mxwmd(PxQ0?$`GSQNtb$dt
z!+m3JvCr52yw|Sh4sx#Fb?r>)Ue63#W-+bSbhwVMTaK9v3@pPWl|w_8W4Oh3H}4o;
zVB04IOlERgt)HAswj`V5n_H7p&GE^t$wYI!wPo|vl+0=yH*N1tAGgOH_i5n_h8qGb
zp5@%RxjnPJLWl6ItghtQ^^#|@QmG9NDI>#H)^+-<(`H&->XB>vi0#Rl1#)R9>)QEo
z$4jeKS>4X&ZQVE9Y?~{4!@haa=Xax?oAWyY#k8vCJ+s#&J*!}Lk~W!E^O?FQe9Lvb
zK{MwOZA>ME1M;OswXxOru1`F$ZCB^RT|HM9FIlQ8)k@7!!Sbw(Z4MMI!yg;by{zdN
zmUC>BV(0kQ<Cd9|tFTw@cl2@ds#>?ae#JeSHe0(i%Wytpoyc4MDYcO?@r(v-m8`zU
z4jJ?#54Z-O(Fi13gSM8jgM7RrXHqYQm33N^tm>@aBbUV#8<b75>dF1bX@P}lQfXzX
zArIJk#<a!I7G*0__sc^C;kg*xp*+N@uvs3?y5r;Ik0*xPv<{|z!H)1}cj=zrJz+Yf
zU)84VWo*<N({pBbkq}n0*w0w7ZZytKb{m%O=7NA6Xwb9~K2@7xm<IV>U$<P<dbNJ0
zULhORatan<nwCRAn>D7I#Hs{Am1|~UjGtO7U^TSD4(NdqFrWzM;YGLrufrvHA3lW7
z;cK`8-@rBa4t|86;aB(r7hnZ4l(8C@VJ+5SBR1m(+=$z-13PgK?!_(~z(E|w5j=v&
za15Wo<9Gs3<0MYuQ+NiS#pm#Od;wp>H}Floh;QKs_z8ZBpW#<{9dF>b_zV7qe@Y;s
zq)3(0VrhxAN?I+gml6_v_2W${<;|$zOTE-icXR9rlsDmyAf1>iZ(@7)D*OJ`yt%Q6
zXG&G|vYOhJjq5ffH*ZhPfJwlwgt(iL9Dw&0$OqsJ)_XSUL`o^K0YbNVa=y$`D>#nX
zRj%C-S7Pb{!oOhGtR;3KVPCNKHN|48L@6iOjhkYMT1E*a2evIu#A3*7c~DW*a!M^B
z+p&{a;Mp$twsx9{Ckp%fki7`+!e#gvz9h(g4?n<9@H+x7#6<+rl^7?OuEDhg(*!25
z1zT|^?!q=~C(w4`qu7IwVJ{xU!<fdSs1syu97hL>c#2^ABmwsfp2c%`9-qMr_!7R1
zui&czfZxV<1o&nk`A7+jg5pPWL$c79b8Oc+M$!_PZ#9g#J4T>PNb7n1zkB}g|96}t
z5=Ie-BJlr?0G4<5b@F3>zFm~p+Hty$(#0Fsn-(-Mp^mHY@t_<hI`fAi-N!>&Dx}kb
bl7!kn{vm)~?xOR5u2<IR{0{(mmvnyt=?f(|

literal 0
HcmV?d00001

diff --git a/java/datastax-v4/connection-EKS-SigV4/src/main/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplication.java b/java/datastax-v4/connection-EKS-SigV4/src/main/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplication.java
new file mode 100644
index 0000000..c2b36b4
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/src/main/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplication.java
@@ -0,0 +1,73 @@
+package com.example.mykeyspacessigv4springbootapp;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
+
+import javax.annotation.PreDestroy;
+import java.io.File;
+import java.net.InetSocketAddress;
+import java.security.NoSuchAlgorithmException;
+import java.time.LocalDate;
+import javax.net.ssl.SSLContext;
+
+import com.datastax.oss.driver.api.core.CqlSession;
+import com.datastax.oss.driver.api.core.ConsistencyLevel;
+import com.datastax.oss.driver.api.core.cql.SimpleStatement;
+import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
+import software.aws.mcs.auth.SigV4AuthProvider;
+
+@SpringBootApplication
+public class Mykeyspacessigv4springbootappApplication {
+
+	private CqlSession session;
+
+	public static void main(String[] args) {
+		SpringApplication.run(Mykeyspacessigv4springbootappApplication.class, args);
+	}
+
+	@Bean
+	public static PropertySourcesPlaceholderConfigurer propertySourcesPlaceholderConfigurer() {
+		PropertySourcesPlaceholderConfigurer properties = new PropertySourcesPlaceholderConfigurer();
+		properties.setLocation(new ClassPathResource("application.conf"));
+		properties.setIgnoreResourceNotFound(false);
+		properties.setIgnoreUnresolvablePlaceholders(false);
+		return properties;
+	}
+
+	@Bean
+	public CqlSession cqlSession() throws NoSuchAlgorithmException {
+		String cassandraHost = System.getenv("CASSANDRA_HOST");
+		String cassandraDC = System.getenv("CASSANDRA_DC");
+
+		var builder = CqlSession.builder()
+				.addContactPoint(new InetSocketAddress(cassandraHost.split(":")[0], Integer.parseInt(cassandraHost.split(":")[1])))
+				.withAuthProvider(new SigV4AuthProvider(cassandraDC))
+				.withLocalDatacenter(cassandraDC)
+				.withSslContext(SSLContext.getDefault())
+				.withConfigLoader(DriverConfigLoader.fromClasspath("application.conf"));
+
+		session = builder.build();
+
+		// Insert statement
+		String query = "INSERT INTO aws.user (username,fname,last_update_date,lname) VALUES ('test','random',dateOf(now()),'k')";
+		SimpleStatement statement = SimpleStatement.newInstance(query).setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM);
+		session.execute(statement);
+		System.out.println("Insert operation was successful. The following row was added:");
+		System.out.println("Username: test");
+		System.out.println("First Name: random");
+		System.out.println("Last Update Date: " + LocalDate.now());
+		System.out.println("Last Name: k");
+
+		return session;
+	}
+
+	@PreDestroy
+	public void preDestroy() {
+		if (session != null) {
+			session.close();
+		}
+	}
+}
diff --git a/java/datastax-v4/connection-EKS-SigV4/src/main/resources/application.conf b/java/datastax-v4/connection-EKS-SigV4/src/main/resources/application.conf
new file mode 100644
index 0000000..b75fa68
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/src/main/resources/application.conf
@@ -0,0 +1,17 @@
+datastax-java-driver {
+  basic.contact-points = ["cassandra.us-east-1.amazonaws.com:9142"]
+  basic.load-balancing-policy.local-datacenter = "us-east-1"
+  advanced.auth-provider {
+    class = software.aws.mcs.auth.SigV4AuthProvider
+    aws-region = "us-east-1"
+  }
+  advanced.ssl-engine-factory {
+    class = DefaultSslEngineFactory
+    truststore-path = "/usr/app/cassandra_truststore.jks"
+    truststore-password = "test"
+  }
+}
+cassandra {
+  host = ${?CASSANDRA_HOST}
+  dc = ${?CASSANDRA_DC}
+}
diff --git a/java/datastax-v4/connection-EKS-SigV4/src/main/resources/logback.xml b/java/datastax-v4/connection-EKS-SigV4/src/main/resources/logback.xml
new file mode 100644
index 0000000..9f31eed
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/src/main/resources/logback.xml
@@ -0,0 +1,13 @@
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <!-- encoders are assigned the type
+             ch.qos.logback.classic.encoder.PatternLayoutEncoder by default -->
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="debug">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>
diff --git a/java/datastax-v4/connection-EKS-SigV4/src/test/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplicationTests.java b/java/datastax-v4/connection-EKS-SigV4/src/test/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplicationTests.java
new file mode 100644
index 0000000..6c44092
--- /dev/null
+++ b/java/datastax-v4/connection-EKS-SigV4/src/test/java/com/example/mykeyspacessigv4springbootapp/Mykeyspacessigv4springbootappApplicationTests.java
@@ -0,0 +1,13 @@
+package com.example.mykeyspacessigv4springbootapp;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class Mykeyspacessigv4springbootappApplicationTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}