diff --git a/src/main/java/kinesisencryption/kcl/EncryptedConsumerWithKCL.java b/src/main/java/kinesisencryption/kcl/EncryptedConsumerWithKCL.java
index aad6b8c..c99e4d6 100644
--- a/src/main/java/kinesisencryption/kcl/EncryptedConsumerWithKCL.java
+++ b/src/main/java/kinesisencryption/kcl/EncryptedConsumerWithKCL.java
@@ -48,13 +48,13 @@ public static void main(String[] args) throws Exception
         String workerId = InetAddress.getLocalHost().getCanonicalHostName() + ":" + UUID.randomUUID();
         String streamName = KinesisEncryptionUtils.getProperties().getProperty("stream_name");
         String appName = KinesisEncryptionUtils.getProperties().getProperty("kcl_name");
-        String endpoint = KinesisEncryptionUtils.getProperties().getProperty("kinesis_endpoint");
+        String ddbRegion = KinesisEncryptionUtils.getProperties().getProperty("ddb_region_4_kcl");
         KinesisClientLibConfiguration kinesisClientLibConfiguration =
                 new KinesisClientLibConfiguration(appName,
                         streamName,
                         credentialsProvider,
                         workerId);
-        kinesisClientLibConfiguration.withInitialPositionInStream(INITIAL_POSITION_IN_STREAM).withKinesisEndpoint(endpoint);
+        kinesisClientLibConfiguration.withInitialPositionInStream(INITIAL_POSITION_IN_STREAM).withRegionName(ddbRegion);
 
         IRecordProcessorFactory recordProcessorFactory = new EncryptedKCLRecordProcessorFactory();
         Worker worker = new Worker(recordProcessorFactory, kinesisClientLibConfiguration);
diff --git a/src/main/resources/app.properties b/src/main/resources/app.properties
index 4106bd1..88a81ca 100644
--- a/src/main/resources/app.properties
+++ b/src/main/resources/app.properties
@@ -6,4 +6,5 @@ kinesis_endpoint=kinesis.us-east-1.amazonaws.com
 kms_endpoint=kms.us-east-1.amazonaws.com
 sharditerator_type=TRIM_HORIZON
 kcl_name=EncryptedKCL
+ddb_region_4_kcl=us-west-2
 encryption_context=cars
\ No newline at end of file