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
-
Invalid KafkaStreams as a result of Decoder problems
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