diff --git a/pom.xml b/pom.xml index 5c8e8e54..5a15d3e2 100644 --- a/pom.xml +++ b/pom.xml @@ -25,7 +25,7 @@ - 1.11.271 + 1.11.272 1.0.392 libsqlite4java ${project.build.directory}/test-lib diff --git a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java index d42b9aff..619f3eaf 100644 --- a/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java +++ b/src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java @@ -18,7 +18,6 @@ import java.util.HashSet; import java.util.List; import java.util.Set; -import com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient; import org.junit.After; import org.junit.AfterClass; import org.junit.Assert; @@ -91,13 +90,11 @@ public class ShardSyncTaskIntegrationTest { new KinesisClientLeaseManager("ShardSyncTaskIntegrationTest", new AmazonDynamoDBClient(credentialsProvider), useConsistentReads); - - AmazonKinesisClient client = new AmazonDynamoDBStreamsAdapterClient(); - client.setEndpoint(KINESIS_ENDPOINT); - client.setSignerRegionOverride("us-east-1"); - - kinesisProxy = new KinesisProxy(STREAM_NAME, new DefaultAWSCredentialsProviderChain(), client, 1000L, 50, 1000L, - 50); + + kinesisProxy = + new KinesisProxy(STREAM_NAME, + new DefaultAWSCredentialsProviderChain(), + KINESIS_ENDPOINT); } /**