kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paul Pearcy <ppea...@gmail.com>
Subject New 0.8.2 client compatibility with during failure cases
Date Tue, 06 Jan 2015 15:54:24 GMT
  I have some of my own test cases very similar to the ones
in ProducerFailureHandlingTest.

I moved to the new producer against 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 producer/server setup
- Stop the server
- Send a message
- Call get on the future and it never returns. Doesn't matter if the server
is started again or remains stopped

So, I believe that while 0.8.2 producer is compatible with in the
happy case, but fails to return futures in cases where disconnects have

Is it possible to run the test cases in ProducerFailureHandlingTest.scala


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message