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

fix(kinesis_proxy): fix AmazonKinesis client class name check

Browse source
This commit is contained in:
zekailiu 2019-12-23 17:28:23 -08:00
parent 124a602515
commit 6b287424d9
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.");