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

Merge pull request #4 from fivetran/fix_amazon_kinesis_client_check_56476

Browse source 
fix(kinesis_proxy): fix AmazonKinesis client class name check
This commit is contained in:
Zekai Liu 2020-01-02 11:40:33 -08:00 committed by GitHub
commit e8dcb0a810
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java vendored
View file

@ -217,7 +217,7 @@ public class KinesisProxy implements IKinesisProxyExtended {
this.maxListShardsRetryAttempts = maxListShardsRetryAttempts; this.maxListShardsRetryAttempts = maxListShardsRetryAttempts;
try { try {
if (Class.forName("com.fivetran.external.com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient") if (Class.forName("com.amazonaws.services.dynamodbv2.streamsadapter.AmazonDynamoDBStreamsAdapterClient")
.isAssignableFrom(client.getClass())) { .isAssignableFrom(client.getClass())) {
isKinesisClient = false; isKinesisClient = false;
LOG.debug("Client is DynamoDb client, will use DescribeStream."); LOG.debug("Client is DynamoDb client, will use DescribeStream.");