fix(log): elastic log supports truncateFullyAndStartAt (#2913)

superhx · web-flow · commit 2e5a7760b4ec · 2025-09-29T14:27:02.000+08:00
fix(log): elastic log supports truncate

Signed-off-by: Robin Han &lt;hanxvdovehx@gmail.com&gt;
diff --git a/core/src/main/scala/kafka/log/streamaspect/ElasticLog.scala b/core/src/main/scala/kafka/log/streamaspect/ElasticLog.scala
@@ -596,6 +596,12 @@ class ElasticLog(val metaStream: MetaStream,
         }
     }
 
+    override private[log] def truncateFullyAndStartAt(newOffset: Long): Iterable[LogSegment] = {
+        val rst = super.truncateFullyAndStartAt(newOffset)
+        _confirmOffset.set(logEndOffsetMetadata)
+        rst
+    }
+
     def snapshot(snapshot: PartitionSnapshot.Builder): Unit = {
         snapshot.logMeta(logSegmentManager.logMeta())
         snapshot.logEndOffset(confirmOffset)

Original file line number	Diff line number	Diff line change
`@@ -596,6 +596,12 @@ class ElasticLog(val metaStream: MetaStream,`
`596`	`596`	`}`
`597`	`597`	`}`
`598`	`598`
	`599`	`+ override private[log] def truncateFullyAndStartAt(newOffset: Long): Iterable[LogSegment] = {`
	`600`	`+ val rst = super.truncateFullyAndStartAt(newOffset)`
	`601`	`+ _confirmOffset.set(logEndOffsetMetadata)`
	`602`	`+ rst`
	`603`	`+ }`
	`604`	`+`
`599`	`605`	`def snapshot(snapshot: PartitionSnapshot.Builder): Unit = {`
`600`	`606`	`snapshot.logMeta(logSegmentManager.logMeta())`
`601`	`607`	`snapshot.logEndOffset(confirmOffset)`