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?
On Fri, Nov 9, 2012 at 8:17 AM, Bob Cotton <[EMAIL PROTECTED]> 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