From b30217d76f262524c8307d1856e5e9c7198af433 Mon Sep 17 00:00:00 2001
From: Ming-Yen Chung <mingyen066@gmail.com>
Date: Sun, 2 Aug 2026 23:35:31 +0800
Subject: [PATCH] MINOR: Batch the produce in
 MirrorConnectorsIntegrationBaseTest#testConnectorMetrics

---
 .../integration/MirrorConnectorsIntegrationBaseTest.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
index 56d2bf4974093..3ad8897b12d94 100644
--- a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
+++ b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
@@ -1050,8 +1050,11 @@ private void testConnectorMetrics(String format, Supplier<Boolean> assertions) t
         String topic = "test-topic-metrics";
         primary.kafka().createTopic(topic);
         try (KafkaProducer<byte[], byte[]> producer = primary.kafka().createProducer(Map.of())) {
-            for (int i = 0; i < NUM_RECORDS_PRODUCED; i++) {
-                producer.send(new ProducerRecord<>(topic, ("value" + i).getBytes())).get();
+            var futures = IntStream.range(0, NUM_RECORDS_PRODUCED)
+                    .mapToObj(i -> producer.send(new ProducerRecord<byte[], byte[]>(topic, ("value" + i).getBytes())))
+                    .toList();
+            for (var future : futures) {
+                future.get();
             }
         }