I could reproduce this consistently when that test *method* is run
individually. From what I could gather, the __consumer_offset topic
(being accessed in that test) had 50 partitions (default) which took a
while for each of them to be assigned a leader and do other
initialization and that timed out the metadata update wait during the
producer.send. I increased the metadata fetch timeout specifically for
that producer in that test method and was able to get past this. I've
sent a patch here https://reviews.apache.org/r/30013/
-Jaikiran
On Sunday 18 January 2015 12:30 AM, Manikumar Reddy wrote:
I am consistently getting these errors. May be transient errors.
On Sun, Jan 18, 2015 at 12:05 AM, Harsha <ka...@harsha.io> wrote:
I don't see any failures in tests with the latest trunk or 0.8.2. I ran
it few times in a loop.
-Harsha
On Sat, Jan 17, 2015, at 08:38 AM, Manikumar Reddy wrote:
ProducerFailureHandlingTest.testCannotSendToInternalTopic is failing on
both 0.8.2 and trunk.
Error on 0.8.2:
kafka.api.ProducerFailureHandlingTest > testCannotSendToInternalTopic
FAILED
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: Failed to update
metadata
after 3000 ms.
at
org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:437)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:352)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:248)
at
kafka.api.ProducerFailureHandlingTest.testCannotSendToInternalTopic(ProducerFailureHandlingTest.scala:309)
Caused by:
org.apache.kafka.common.errors.TimeoutException: Failed to update
metadata after 3000 ms.
Error on Trunk:
kafka.api.test.ProducerFailureHandlingTest >
testCannotSendToInternalTopic
FAILED
java.lang.AssertionError: null
at org.junit.Assert.fail(Assert.java:69)
at org.junit.Assert.assertTrue(Assert.java:32)
at org.junit.Assert.assertTrue(Assert.java:41)
at
kafka.api.test.ProducerFailureHandlingTest.testCannotSendToInternalTopic(ProducerFailureHandlingTest.scala:312)
