remove unused code

TaiJuWu · TaiJuWu · commit 8509b833c0db · 2025-10-04T09:51:55.000+08:00
diff --git a/storage/src/test/java/org/apache/kafka/storage/internals/log/UnifiedLogTest.java b/storage/src/test/java/org/apache/kafka/storage/internals/log/UnifiedLogTest.java
@@ -624,11 +624,6 @@ private LeaderEpochFileCache epochCache(UnifiedLog log) {
         return log.leaderEpochCache();
     }
 
-    private LogAppendInfo appendEndTxnMarkerAsLeader(UnifiedLog log, long producerId, short producerEpoch, ControlRecordType controlType, long timestamp) throws IOException {
-        MemoryRecords records = MemoryRecords.withEndTransactionMarker(producerId, producerEpoch, new EndTransactionMarker(controlType, 0));
-        return log.appendAsLeader(records, 0);
-    }
-
     private UnifiedLog createLog(File dir, LogConfig config) throws IOException {
         return createLog(dir, config, false);
     }

Original file line number	Diff line number	Diff line change
`@@ -624,11 +624,6 @@ private LeaderEpochFileCache epochCache(UnifiedLog log) {`
`624`	`624`	`return log.leaderEpochCache();`
`625`	`625`	`}`
`626`	`626`
`627`		`- private LogAppendInfo appendEndTxnMarkerAsLeader(UnifiedLog log, long producerId, short producerEpoch, ControlRecordType controlType, long timestamp) throws IOException {`
`628`		`- MemoryRecords records = MemoryRecords.withEndTransactionMarker(producerId, producerEpoch, new EndTransactionMarker(controlType, 0));`
`629`		`- return log.appendAsLeader(records, 0);`
`630`		`- }`
`631`		`-`
`632`	`627`	`private UnifiedLog createLog(File dir, LogConfig config) throws IOException {`
`633`	`628`	`return createLog(dir, config, false);`
`634`	`629`	`}`