Added property for ddb region

cheefoo · Jan 30, 2017 · 12c89cd · 12c89cd
1 parent a9e434f
commit 12c89cd
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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