diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java index c093dced..ce658c51 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java @@ -117,6 +117,7 @@ public class HierarchicalShardSyncer { final boolean ignoreUnexpectedChildShards, final MetricsScope scope, List latestShards) throws DependencyException, InvalidStateException, ProvisionedThroughputException, KinesisClientLibIOException { + //TODO: Need to add multistream support for this https://sim.amazon.com/issues/KinesisLTR-191 final boolean isLeaseTableEmpty = leaseRefresher.isLeaseTableEmpty(); if (!CollectionUtils.isNullOrEmpty(latestShards)) {