diff --git a/storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsTestHelper.java b/storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsTestHelper.java index 6cf90d28b12cb..bc82b83437ddd 100644 --- a/storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsTestHelper.java +++ b/storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsTestHelper.java @@ -923,7 +923,9 @@ public static void testFailureToFenceEpoch( long producerId; int initialProducerEpoch; - try (var producer1 = createTransactionalProducer(clusterInstance, "transactional-producer")) { + // Use a shorter request timeout to bound the graceful close delay when the fencing probe leaves producer1 in an empty transaction. + try (var producer1 = createTransactionalProducer( + clusterInstance, "transactional-producer", 60000, 60000, 120000, 1000)) { producer1.initTransactions(); producer1.beginTransaction();