From 6b287424d956062c59ae68bb0a347eac91cd7c71 Mon Sep 17 00:00:00 2001 From: zekailiu Date: Mon, 23 Dec 2019 17:28:23 -0800 Subject: [PATCH] fix(kinesis_proxy): fix AmazonKinesis client class name check --- .../services/kinesis/clientlibrary/proxies/KinesisProxy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java index 6198b2c0..9ace851b 100644 --- a/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java +++ b/src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java @@ -217,7 +217,7 @@ public class KinesisProxy implements IKinesisProxyExtended { this.maxListShardsRetryAttempts = maxListShardsRetryAttempts; 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())) { isKinesisClient = false; LOG.debug("Client is DynamoDb client, will use DescribeStream.");