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

Fixing logging

Browse source
This commit is contained in:
Joshua Kim 2021-05-03 12:47:40 -07:00
parent 300ba1c385
commit 5ba7d4502d
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
View file

@ -490,7 +490,8 @@ public class KinesisProxy implements IKinesisProxyExtended {
} }
final List<Shard> dedupedShards = new ArrayList<>(new LinkedHashSet<>(shards)); final List<Shard> dedupedShards = new ArrayList<>(new LinkedHashSet<>(shards));
if (dedupedShards.size() < shards.size()) { if (dedupedShards.size() < shards.size()) {
LOG.warn("Found duplicate child shards in ListShards response. Request ids - " + requestIds); LOG.warn("Found duplicate shards in response when sync'ing from Kinesis. " +
"Request ids - " + requestIds + ". Response - " + shards);
} }
this.cachedShardMap = dedupedShards.stream().collect(Collectors.toMap(Shard::getShardId, Function.identity())); this.cachedShardMap = dedupedShards.stream().collect(Collectors.toMap(Shard::getShardId, Function.identity()));
this.lastCacheUpdateTime = Instant.now(); this.lastCacheUpdateTime = Instant.now();