private void loadTestSnapshot2(
        MetadataLoader loader,
        long offset
    ) throws Exception {
        loader.handleLoadSnapshot(MockSnapshotReader.fromRecordLists(
                new MetadataProvenance(offset, 100, 4000), asList(
                        singletonList(new ApiMessageAndVersion(new FeatureLevelRecord().
                                setName(MetadataVersion.FEATURE_NAME).
                                setFeatureLevel(IBP_3_3_IV2.featureLevel()), (short) 0)),
                        singletonList(new ApiMessageAndVersion(new TopicRecord().
                                setName("bar").
                                setTopicId(Uuid.fromString("VcL2Mw-cT4aL6XV9VujzoQ")), (short) 0))
                )));
        loader.waitForAllEventsToBeHandled();
    }
Test that we do not leave the catchingUp state until we have loaded up to the high
watermark.
metadata/src/test/java/org/apache/kafka/image/loader/MetadataLoaderTest.java