[ https://issues.apache.org/jira/browse/KAFKA-623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Rosenberg updated KAFKA-623: ---------------------------------- Affects Version/s: 0.8 > It should be possible to re-create KafkaStreams after an exception, without > recreating ConsumerConnector > -------------------------------------------------------------------------------------------------------- > > Key: KAFKA-623 > URL: https://issues.apache.org/jira/browse/KAFKA-623 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.8 > Reporter: Jason Rosenberg > > This issue came out of a discussion on the user mailing list (not something I > experienced directly). > Bob Cotton reported: > "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." > ...... > And then Neha responded: > "This is a bug. Ideally, we should allow restarting the consumer > streams when they encounter an error. > Can you file a JIRA ? > Thanks, > Neha" > Jason -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira