diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-31 11:55:58 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-09-24 14:01:05 -0700 |
| commit | 26fe1f2e296aa78e0fe79c01f0b974dfc8741246 (patch) | |
| tree | f0ae7d24e3b341b550797000b2a80d84b52cefb8 /kafka/streams/errors.py | |
| parent | 2a7aca1630b81669595d753083239ec9fbf66ff5 (diff) | |
| download | kafka-python-26fe1f2e296aa78e0fe79c01f0b974dfc8741246.tar.gz | |
First scratch commit kafka.streams
Diffstat (limited to 'kafka/streams/errors.py')
| -rw-r--r-- | kafka/streams/errors.py | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/kafka/streams/errors.py b/kafka/streams/errors.py new file mode 100644 index 0000000..e35007e --- /dev/null +++ b/kafka/streams/errors.py @@ -0,0 +1,23 @@ +from __future__ import absolute_import + +from kafka.errors import KafkaError, IllegalStateError + + +class StreamsError(KafkaError): + pass + + +class ProcessorStateError(StreamsError): + pass + + +class TopologyBuilderError(StreamsError): + pass + + +class NoSuchElementError(StreamsError): + pass + + +class TaskAssignmentError(StreamsError): + pass |