Handling the exceptions in the Decoder is not a problem. It was just a larger question about what to do in the event the stream gets into a failed state.
Thanks - Bob On Sun, Nov 11, 2012 at 11:01 PM, Jun Rao <jun...@gmail.com> wrote: > Currently, the code in Kafka doesn't expect the decoder to throw > exceptions. Could you write your decoder to return null on exceptions? > > Thanks, > > Jun > > 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 >> > >
