+ // Get the leader's lastIndex and verify followers are fully synced before shutting down the leader
+ AtomicLong leaderLastIndex = new AtomicLong();
+ MemberNode.verifyRaftState(leaderDistributedDataStore, ENTITY_OWNERSHIP_SHARD_NAME,
+ raftState -> leaderLastIndex.set(raftState.getLastIndex()));
+
+ MemberNode.verifyRaftState(follower1Node.configDataStore(), ENTITY_OWNERSHIP_SHARD_NAME,
+ raftState -> assertEquals("Last index", leaderLastIndex.get(), raftState.getLastIndex()));
+
+ MemberNode.verifyRaftState(follower2Node.configDataStore(), ENTITY_OWNERSHIP_SHARD_NAME,
+ raftState -> assertEquals("Last index", leaderLastIndex.get(), raftState.getLastIndex()));
+
+ MemberNode.verifyRaftState(follower4Node.configDataStore(), ENTITY_OWNERSHIP_SHARD_NAME,
+ raftState -> assertEquals("Last index", leaderLastIndex.get(), raftState.getLastIndex()));
+