diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/config/KinesisClientLibConfigurator.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/config/KinesisClientLibConfigurator.java index 3dbd30a8..e239f967 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/config/KinesisClientLibConfigurator.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/config/KinesisClientLibConfigurator.java @@ -130,7 +130,7 @@ public class KinesisClientLibConfigurator { // Decode the CloudWatch credentials provider if it exists. If not use the Kinesis credentials provider. AWSCredentialsProvider providerCloudWatch; String propCredentialsProviderCloudWatchValue = properties.getProperty(PROP_CREDENTIALS_PROVIDER_CLOUDWATCH); - if (propCredentialsProviderDynamoDBValue == null) { + if (propCredentialsProviderCloudWatchValue == null) { providerCloudWatch = provider; } else { providerCloudWatch = awsCPPropGetter.decodeValue(propCredentialsProviderCloudWatchValue);