Uploaded image for project: 'mod-data-import'
  1. mod-data-import
  2. MODDATAIMP-727

Fix "Producer closed while send in progress" after update to vertx 4.3.4

    XMLWordPrintable

Details

    • Folijet Sprint 151
    • 3
    • Folijet
    • Orchid (R1 2023)

    Description

      In previous versions, code was added to close producers because managing producers through vertx was causing memory leaks.

      After upgrading to vertx 4.3.4 we received next error messages:

      07:30:59.846 [vert.x-eventloop-thread-1] [] ERROR WriteStreamWrapper   Next chunk has failed with errors chunkId: ec646723-f13a-4287-8a64-4562ce4480ad chunkNumber: 1
      org.apache.kafka.common.KafkaException: Producer closed while send in progress
      	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:929) ~[mod-data-import-fat.jar:?]
      	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:905) ~[mod-data-import-fat.jar:?]
      	at io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.lambda$send$4(KafkaWriteStreamImpl.java:79) ~[mod-data-import-fat.jar:?]
      	at io.vertx.core.impl.ContextBase.lambda$null$0(ContextBase.java:137) ~[mod-data-import-fat.jar:?]
      	at io.vertx.core.impl.ContextInternal.dispatch(ContextInternal.java:264) ~[mod-data-import-fat.jar:?]
      ......
      Caused by: org.apache.kafka.common.KafkaException: Requested metadata update after close
      	at org.apache.kafka.clients.producer.internals.ProducerMetadata.awaitUpdate(ProducerMetadata.java:126) ~[mod-data-import-fat.jar:?]
      	at org.apache.kafka.clients.producer.KafkaProducer.waitOnMetadata(KafkaProducer.java:1067) ~[mod-data-import-fat.jar:?]
      	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:926) ~[mod-data-import-fat.jar:?]
      

       

      TestRail: Results

        Attachments

          Issue Links

            Activity

              People

                afedasiuk Aliaksandr Fedasiuk
                afedasiuk Aliaksandr Fedasiuk
                Votes:
                0 Vote for this issue
                Watchers:
                6 Start watching this issue

                Dates

                  Created:
                  Updated:
                  Resolved:

                  TestRail: Runs

                    TestRail: Cases