luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Updating the version of the AWS SDK. Reverting the Integ test to use ListShards instead of DescribeStream API.

Browse source
This commit is contained in:
Sahil Palvia 2018-02-05 16:53:28 -08:00
parent 51f28e3345
commit 2715728783
2 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pom.xml
View file

@ -25,7 +25,7 @@
</licenses>
<properties>
<aws-java-sdk.version>1.11.271</aws-java-sdk.version>
<aws-java-sdk.version>1.11.272</aws-java-sdk.version>
<sqlite4java.version>1.0.392</sqlite4java.version>
<sqlite4java.native>libsqlite4java</sqlite4java.native>
<sqlite4java.libpath>${project.build.directory}/test-lib</sqlite4java.libpath>

11
src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java
View file

@ -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;
@ -92,12 +91,10 @@ public class 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);
}
/**