diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/DeterministicShuffleShardSyncLeaderDeciderTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/DeterministicShuffleShardSyncLeaderDeciderTest.java index 2e228a8a..b300f355 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/DeterministicShuffleShardSyncLeaderDeciderTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/DeterministicShuffleShardSyncLeaderDeciderTest.java @@ -78,7 +78,7 @@ public class DeterministicShuffleShardSyncLeaderDeciderTest { List leases = getLeases(5, true, true, true); when(leaseRefresher.listLeases()).thenReturn(leases); boolean isLeader = leaderDecider.isLeader(WORKER_ID); - assertTrue("IsLeader should return false if leases have no owner", isLeader); + assertTrue("IsLeader should return true if leases have no owner", isLeader); } @Test