Hello,
I have some of my own test cases very similar to the ones
in ProducerFailureHandlingTest.
I moved to the new producer against 0.8.1.1 and all of my test cases around
disconnects fail. Moving to use 0.8.2-beta on server side things succeed.
Here is an example test:
- Healthy
Paul,
That behavior is currently expected, see
https://issues.apache.org/jira/browse/KAFKA-1788. There are currently no
client-side timeouts in the new producer, so the message just sits there
forever waiting for the server to come back so it can try to send it.
If you already have tests for a
