diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommitterTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommitterTest.java
index <HASH>..<HASH> 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommitterTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaCommitterTest.java
@@ -27,6 +27,7 @@ import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 
 import java.io.IOException;
+import java.time.Duration;
 import java.util.Collections;
 import java.util.List;
 import java.util.Properties;
@@ -62,6 +63,8 @@ public class KafkaCommitterTest {
             List<KafkaCommittable> recovered = committer.commit(committables);
             assertThat(recovered, contains(committables.toArray()));
             assertThat(recyclable.isRecycled(), equalTo(false));
+            // FLINK-25531: force the producer to close immediately, else it would take 1 hour
+            producer.close(Duration.ZERO);
         }
     }
[FLINK-<I>][connectors/kafka] Force immediate shutdown of FlinkInternalKafkaProducer to speed up testRetryComittableOnRetriableError