perf(metadata): remove empty RangeMetadata (#2709)

lifepuzzlefun · web-flow · commit 014d2d286115 · 2025-07-28T17:20:40.000+08:00
diff --git a/metadata/src/main/java/org/apache/kafka/controller/stream/StreamRuntimeMetadata.java b/metadata/src/main/java/org/apache/kafka/controller/stream/StreamRuntimeMetadata.java
@@ -176,6 +176,11 @@ public List<RangeMetadata> checkRemovableRanges() {
             RangeMetadata range = ranges.get(i);
             if (startOffset <= range.startOffset() && range.endOffset() <= endOffset) {
                 removableRanges.add(range);
+                continue;
+            }
+            // remove middle ranges contains no message
+            if (range.startOffset() == range.endOffset()) {
+                removableRanges.add(range);
             }
         }
         return removableRanges;

Original file line number	Diff line number	Diff line change
`@@ -176,6 +176,11 @@ public List<RangeMetadata> checkRemovableRanges() {`
`176`	`176`	`RangeMetadata range = ranges.get(i);`
`177`	`177`	`if (startOffset <= range.startOffset() && range.endOffset() <= endOffset) {`
`178`	`178`	`removableRanges.add(range);`
	`179`	`+ continue;`
	`180`	`+ }`
	`181`	`+ // remove middle ranges contains no message`
	`182`	`+ if (range.startOffset() == range.endOffset()) {`
	`183`	`+ removableRanges.add(range);`
`179`	`184`	`}`
`180`	`185`	`}`
`181`	`186`	`return removableRanges;`