Source code for base.kafka.errors

"""Kafka wrapper exceptions."""



[docs]
class TooManyFailedAttemptsError(Exception):
    """Raised when required Kafka topics never become available."""




[docs]
class KafkaMessageFetchException(Exception):
    """Raised when Kafka returns a permanent consumer error."""