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