Description
Saw the following transient unit test failure.
kafka.producer.ProducerTest > testSendWithDeadBroker FAILED
java.lang.AssertionError: Message set should have 1 message
at org.junit.Assert.fail(Assert.java:69)
at org.junit.Assert.assertTrue(Assert.java:32)
at kafka.producer.ProducerTest.testSendWithDeadBroker(ProducerTest.scala:245)