Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2054 Fix Kafka transient unit test failures
  3. KAFKA-3875

Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

    XMLWordPrintableJSON

    Details

      Description

      It failed in a couple of builds.

      java.lang.AssertionError: Should have offset 100 but only successfully sent 0 expected:<100> but was:<0>
      	at org.junit.Assert.fail(Assert.java:88)
      	at org.junit.Assert.failNotEquals(Assert.java:834)
      	at org.junit.Assert.assertEquals(Assert.java:645)
      	at kafka.api.BaseProducerSendTest.sendAndVerifyTimestamp(BaseProducerSendTest.scala:228)
      	at kafka.api.BaseProducerSendTest.testSendNonCompressedMessageWithCreateTime(BaseProducerSendTest.scala:170)
      

      And standard out:

      org.scalatest.junit.JUnitTestFailedError: Send callback returns the following exception
      	at org.scalatest.junit.AssertionsForJUnit$class.newAssertionFailedException(AssertionsForJUnit.scala:103)
      	at org.scalatest.junit.JUnitSuite.newAssertionFailedException(JUnitSuite.scala:79)
      	at org.scalatest.Assertions$class.fail(Assertions.scala:1348)
      	at org.scalatest.junit.JUnitSuite.fail(JUnitSuite.scala:79)
      	at kafka.api.BaseProducerSendTest$callback$4$.onCompletion(BaseProducerSendTest.scala:209)
      	at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:109)
      	at org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:155)
      	at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortExpiredBatches(RecordAccumulator.java:245)
      	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:211)
      	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
      	at java.lang.Thread.run(Thread.java:745)
      Caused by: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for topic-0
      
      java.lang.IllegalStateException: Cannot send after the producer is closed.
      	at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:172)
      	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:466)
      	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430)
      	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:353)
      	at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
      	at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
      	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
      	at scala.collection.immutable.Range.foreach(Range.scala:160)
      	at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
      	at scala.collection.AbstractTraversable.map(Traversable.scala:104)
      	at kafka.api.BaseProducerSendTest$CloseCallback$1.onCompletion(BaseProducerSendTest.scala:415)
      	at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:107)
      	at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:318)
      	at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:278)
      	at org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:57)
      	at org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:364)
      	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
      	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
      	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
      	at java.lang.Thread.run(Thread.java:745)
      

      https://jenkins.confluent.io/job/kafka-trunk/905/
      https://jenkins.confluent.io/job/kafka-trunk/919 (the output is similar to the first build)

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                junrao Jun Rao
                Reporter:
                ijuma Ismael Juma
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: