diff --git a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/KinesisBinderConfiguration.java b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/KinesisBinderConfiguration.java
index 0a6e362..e71635f 100644
--- a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/KinesisBinderConfiguration.java
+++ b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/KinesisBinderConfiguration.java
@@ -34,7 +34,7 @@ import org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStrea
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.integration.aws.lock.DynamoDbLockRegistry;
-import org.springframework.integration.aws.metadata.DynamoDbMetaDataStore;
+import org.springframework.integration.aws.metadata.DynamoDbMetadataStore;
 import org.springframework.integration.metadata.ConcurrentMetadataStore;
 import org.springframework.integration.support.locks.LockRegistry;
 
@@ -121,7 +121,7 @@ public class KinesisBinderConfiguration {
 	public ConcurrentMetadataStore kinesisCheckpointStore(AmazonDynamoDBAsync dynamoDB) {
 		KinesisBinderConfigurationProperties.Checkpoint checkpoint = this.configurationProperties.getCheckpoint();
 
-		DynamoDbMetaDataStore kinesisCheckpointStore = new DynamoDbMetaDataStore(dynamoDB, checkpoint.getTable());
+		DynamoDbMetadataStore kinesisCheckpointStore = new DynamoDbMetadataStore(dynamoDB, checkpoint.getTable());
 		kinesisCheckpointStore.setReadCapacity(checkpoint.getReadCapacity());
 		kinesisCheckpointStore.setWriteCapacity(checkpoint.getWriteCapacity());
 		kinesisCheckpointStore.setCreateTableDelay(checkpoint.getCreateDelay());
diff --git a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/properties/KinesisBinderConfigurationProperties.java b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/properties/KinesisBinderConfigurationProperties.java
index 1e0c4cc..f08b6ea 100644
--- a/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/properties/KinesisBinderConfigurationProperties.java
+++ b/spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/properties/KinesisBinderConfigurationProperties.java
@@ -18,7 +18,7 @@ package org.springframework.cloud.stream.binder.kinesis.properties;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.integration.aws.lock.DynamoDbLockRegistry;
-import org.springframework.integration.aws.metadata.DynamoDbMetaDataStore;
+import org.springframework.integration.aws.metadata.DynamoDbMetadataStore;
 
 /**
  *
@@ -94,7 +94,7 @@ public class KinesisBinderConfigurationProperties {
 
 	public static class Checkpoint {
 
-		private String table = DynamoDbMetaDataStore.DEFAULT_TABLE_NAME;
+		private String table = DynamoDbMetadataStore.DEFAULT_TABLE_NAME;
 
 		private long readCapacity = 1L;