private boolean invariantB(OffsetSync iSync, OffsetSync jSync, int i, int j) {
        long bound = jSync.upstreamOffset() + (1L << j) - (1L << i);
        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