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

MINOR: Update comment in consumeAction (#14335) 

Reviewers: Satish Duggana <satishd@apache.org>, Divij Vaidya <diviv@amazon.com>
This commit is contained in:
Luke Chen 2023-09-06 00:06:28 +08:00 committed by Satish Duggana
parent 33b385e3fa
commit b7df99abec
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
storage/src/test/java/org/apache/kafka/tiered/storage/actions/ConsumeAction.java
View File

@ -81,7 +81,7 @@ public final class ConsumeAction implements TieredStorageTestAction {
context.consume(topicPartition, expectedTotalCount, fetchOffset);
// (A) Comparison of records consumed with records in the second-tier storage.
// Reads all records physically found in the second-tier storage ∂for the given topic-partition.
// Reads all records physically found in the second-tier storage for the given topic-partition.
// The resulting sequence is sorted by records offset, as there is no guarantee on ordering from
// the LocalTieredStorageSnapshot.
List<Record> tieredStorageRecords = tieredStorageRecords(context, topicPartition);
@ -92,8 +92,7 @@ public final class ConsumeAction implements TieredStorageTestAction {
.findFirst();
if (!firstExpectedRecordOpt.isPresent()) {
// If no records could be found in the second-tier storage or their offset are less
// than the consumer fetch offset, no record would be consumed from that storage.
// If no records could be found in the second-tier storage, no record would be consumed from that storage.
if (expectedFromSecondTierCount > 0) {
fail("Could not find any record with offset >= " + fetchOffset + " from tier storage.");
}