Wow, this seems a bit restrictive. Can you point me to the discussion on this? What exactly is an "invalid stream", how can you test for this?
Jason On Fri, Nov 9, 2012 at 8:17 AM, Bob Cotton <bcot...@rallydev.com> wrote: > During the implementation of a custom Encoder/Decoder we noticed that > should the Decoder throw an exception, the KafkaStream that it is in use > becomes invalid. > > Searching the mailing list indicates that the only way to recover from an > invalid stream is to shutdown the whole high-level consumer and restart. > > Is there a better way to recover from this? > > Thanks for the responsiveness on the mailing list. > - Bob >
