Here's the post I saw: http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201201.mbox/%3CCAOG_4QbzXPJujmOjLuiHOspLfCkA+-gQP2CkN+J-zyg=kn7...@mail.gmail.com%3E
On Fri, Nov 9, 2012 at 10:22 AM, Jason Rosenberg <j...@squareup.com> wrote: > 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 >> > >
