summaryrefslogtreecommitdiff
path: root/kafka/streams/errors.py
blob: e35007e5a875e77176d0acf1d98feba3e455bd66 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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