Skip to content

Commit 113be7b

Browse files
committed
fix build
1 parent 8d2d934 commit 113be7b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

storage/src/test/java/org/apache/kafka/storage/internals/log/LogTestUtils.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import org.apache.kafka.common.record.MemoryRecords;
2525
import org.apache.kafka.common.utils.Time;
2626
import org.apache.kafka.server.common.RequestLocal;
27+
import org.apache.kafka.server.common.TransactionVersion;
2728
import org.apache.kafka.server.config.ServerLogConfigs;
2829
import org.apache.kafka.server.util.Scheduler;
2930
import org.apache.kafka.storage.log.metrics.BrokerTopicStats;
@@ -55,7 +56,7 @@ public static LogAppendInfo appendEndTxnMarkerAsLeader(UnifiedLog log,
5556
int leaderEpoch) {
5657
MemoryRecords records = endTxnRecords(controlType, producerId, producerEpoch, 0L, coordinatorEpoch, leaderEpoch, timestamp);
5758

58-
return log.appendAsLeader(records, leaderEpoch, AppendOrigin.COORDINATOR, RequestLocal.noCaching(), VerificationGuard.SENTINEL);
59+
return log.appendAsLeader(records, leaderEpoch, AppendOrigin.COORDINATOR, RequestLocal.noCaching(), VerificationGuard.SENTINEL, TransactionVersion.TV_UNKNOWN);
5960
}
6061

6162
public static MemoryRecords endTxnRecords(ControlRecordType controlRecordType,

0 commit comments

Comments
 (0)