Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Invalid KafkaStreams as a result of Decoder problems


Copy link to this message
-
Re: Invalid KafkaStreams as a result of Decoder problems
Here's the post I saw:
http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201201.mbox/%3CCAOG_4QbzXPJujmOjLuiHOspLfCkA+-gQP2CkN+[EMAIL PROTECTED]%3E
On Fri, Nov 9, 2012 at 10:22 AM, Jason Rosenberg <[EMAIL PROTECTED]> 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 <[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
>>
>
>