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