Source code for loom.streaming.kafka._errors

"""Kafka transport error hierarchy."""

from __future__ import annotations



[docs]
class KafkaClientError(Exception):
    """Base error for Kafka transport operations."""




[docs]
class KafkaConfigurationError(KafkaClientError):
    """Raised when client configuration is invalid or incomplete."""




[docs]
class KafkaProducerError(KafkaClientError):
    """Base error for producer-side failures."""




[docs]
class KafkaSerializationError(KafkaProducerError):
    """Raised when a record cannot be serialized for Kafka output."""




[docs]
class KafkaDeliveryError(KafkaProducerError):
    """Raised when Kafka delivery fails."""




[docs]
class KafkaConsumerError(KafkaClientError):
    """Base error for consumer-side failures."""




[docs]
class KafkaPollError(KafkaConsumerError):
    """Raised when Kafka polling returns a backend error."""




[docs]
class KafkaCommitError(KafkaConsumerError):
    """Raised when Kafka offset commit fails."""




[docs]
class KafkaDeserializationError(KafkaConsumerError):
    """Raised when Kafka payload bytes cannot be decoded."""