[jira] [Resolved] (KAFKA-20837) Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages

["Chia-Ping Tsai (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-20837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chia-Ping Tsai resolved KAFKA-20837.
------------------------------------
    Resolution: Fixed

> Fix slow MirrorConnectorsIntegrationBaseTest#produceMessages
> ------------------------------------------------------------
>
>                 Key: KAFKA-20837
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20837
>             Project: Kafka
>          Issue Type: Test
>            Reporter: Chia-Ping Tsai
>            Assignee: Ming-Yen Chung
>            Priority: Major
>             Fix For: 4.5.0
>
>
> Many mirror tests need to produce a bunch of records, but the helper method blocks until each record is completed. That is freaking slow for all tests...
> We can refactor this while keeping the original timeout behaviour.
> {code:java}
>     protected void produceMessages(Producer<byte[], byte[]> producer, List<ProducerRecord<byte[], byte[]>> records) {
>         Timer timer = Time.SYSTEM.timer(RECORD_PRODUCE_DURATION_MS);
>         try {
>             var futures = records.stream().map(producer::send).toList();
>             for (var f : futures) {
>                 f.get(timer.remainingMs(), TimeUnit.MILLISECONDS);
>                 timer.update();
>             }
>         } catch (ExecutionException | InterruptedException | TimeoutException e) {
>             throw new RuntimeException(e);
>         }
>     }
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)