Jason Rosenberg created KAFKA-623:
-------------------------------------
Summary: 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
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
