private boolean invariantC(OffsetSync iSync, OffsetSync jSync, int i) {
        long bound = jSync.upstreamOffset() + (1L << Math.max(i - 2, 0));
        return iSync == jSync || (bound >= 0 && iSync.upstreamOffset() >= bound);
    }
Start the OffsetSyncStore, blocking until all previous Offset Syncs have been read from backing storage.
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java