[KAFKA-3125] Exception Hierarchy for Streams

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.0.0
• Assignee: Guozhang Wang
• Reporter: Guozhang Wang
• Created: 20/Jan/16 23:39
• Updated: 27/Jan/16 07:09
• Resolved: 26/Jan/16 17:20

Description

Currently Kafka Streams do not have its own exception category: we only have one TopologyException that extends from KafkaException.

It's better to start thinking about categorizing exceptions in Streams with a common parent of "StreamsException". For example:

1. What type of exceptions should be exposed to users at job runtime; what type of exceptions should be exposed at "topology build time".

2. Should KafkaStreaming.start / stop ever need to throw any exceptions?

3. etc.