Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9597

Flaky Test KafkaProducerTest#testInitTransactionTimeout

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Critical
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: producer , unit tests
    • Labels:

      Description

      https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/4866/testReport/junit/org.apache.kafka.clients.producer/KafkaProducerTest/testInitTransactionTimeout/

      java.lang.IllegalStateException: No requests pending for inbound response FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='NONE', nodeId=0, host='host1', port=1000) at org.apache.kafka.clients.MockClient.respond(MockClient.java:345) at org.apache.kafka.clients.MockClient.respond(MockClient.java:319) at org.apache.kafka.clients.producer.KafkaProducerTest.testInitTransactionTimeout(KafkaProducerTest.java:770)

      STDOUT:

      [2020-02-22 08:52:04,203] ERROR [Producer clientId=producer-9] Uncaught error in kafka producer I/O thread: (org.apache.kafka.clients.producer.internals.Sender:241) java.lang.IllegalStateException: No previous metadata update to use at org.apache.kafka.clients.MockClient$DefaultMockMetadataUpdater.updateWithCurrentMetadata(MockClient.java:623) at org.apache.kafka.clients.MockClient.poll(MockClient.java:287) at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:324) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:239) at java.base/java.lang.Thread.run(Thread.java:834) [2020-02-22 08:52:04,863] ERROR [Producer clientId=producer-10] Interrupted while joining ioThread (org.apache.kafka.clients.producer.KafkaProducer:1197) java.lang.InterruptedException at java.base/java.lang.Object.wait(Native Method) at java.base/java.lang.Thread.join(Thread.java:1313) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1194) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1171) at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1147) at org.apache.kafka.clients.producer.KafkaProducerTest.lambda$shouldCloseProperlyAndThrowIfInterrupted$1(KafkaProducerTest.java:295) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) [2020-02-22 08:52:05,343] ERROR Metadata response reported invalid topics [topic abc] (org.apache.kafka.clients.Metadata:295)

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: