root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Test showing MetadataLoader waits until metadata version is known (#19012) 

Reviewers: David Arthur <mumrah@gmail.com>
This commit is contained in:
Ismael Juma 2025-02-24 08:38:45 -08:00 committed by GitHub
parent 48527a1e7f
commit 38c984307c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
metadata/src/test/java/org/apache/kafka/image/loader/MetadataLoaderTest.java
View File

@ -344,15 +344,16 @@ public class MetadataLoaderTest {
setHighWaterMarkAccessor(() -> OptionalLong.of(0L)).
build()) {
loader.installPublishers(publishers).get();
loader.handleCommit(
MockBatchReader.newSingleBatchReader(400, 50, List.of(
new ApiMessageAndVersion(new FeatureLevelRecord()
.setName(MetadataVersion.FEATURE_NAME)
.setFeatureLevel(MINIMUM_VERSION.featureLevel()), (short) 0)))
);
loadEmptySnapshot(loader, 200);
loader.waitForAllEventsToBeHandled();
assertFalse(publishers.get(0).firstPublish.isDone());
loader.handleCommit(MockBatchReader.newSingleBatchReader(250, 50, List.of(
new ApiMessageAndVersion(new FeatureLevelRecord()
.setName(MetadataVersion.FEATURE_NAME)
.setFeatureLevel(MINIMUM_VERSION.featureLevel()), (short) 0)))
);
publishers.get(0).firstPublish.get(10, TimeUnit.SECONDS);
assertEquals(200L, loader.lastAppliedOffset());
assertEquals(250L, loader.lastAppliedOffset());
loadEmptySnapshot(loader, 300);
assertEquals(300L, loader.lastAppliedOffset());
assertEquals(new SnapshotManifest(new MetadataProvenance(300, 100, 4000, true), 3000000L),