diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
index 30c564cb..61606aef 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
@@ -183,11 +183,11 @@ public class LeaseManagementConfig {
 
     public LeaseManagementFactory leaseManagementFactory() {
         if (leaseManagementFactory == null) {
-            new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(), EPSILON_MS,
-                    maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(), kinesisProxy(),
-                    initialPositionInStream(), cleanupLeasesUponShardCompletion(), ignoreUnexpectedChildShards(),
-                    shardSyncIntervalMillis(), metricsFactory(), executorService(), tableName(), amazonDynamoDB(),
-                    consistentReads());
+            leaseManagementFactory = new DynamoDBLeaseManagementFactory(workerIdentifier(), failoverTimeMillis(),
+                    EPSILON_MS, maxLeasesForWorker(), maxLeasesToStealAtOneTime(), maxLeaseRenewalThreads(),
+                    kinesisProxy(), initialPositionInStream(), cleanupLeasesUponShardCompletion(),
+                    ignoreUnexpectedChildShards(), shardSyncIntervalMillis(), metricsFactory(), executorService(),
+                    tableName(), amazonDynamoDB(), consistentReads());
         }
         return leaseManagementFactory;
     }