pykafka.exceptions¶

Author: Keith Bourgoin, Emmett Butler

exception pykafka.exceptions.ConsumerCoordinatorNotAvailable¶

Bases: pykafka.exceptions.ProtocolClientError

The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created.

exception pykafka.exceptions.ConsumerStoppedException¶

Bases: pykafka.exceptions.KafkaException

Indicates that the consumer was stopped when an operation was attempted that required it to be running

exception pykafka.exceptions.InvalidMessageError¶

Bases: pykafka.exceptions.ProtocolClientError

This indicates that a message contents does not match its CRC

exception pykafka.exceptions.InvalidMessageSize¶

Bases: pykafka.exceptions.ProtocolClientError

The message has a negative size

exception pykafka.exceptions.KafkaException¶

Bases: exceptions.Exception

Generic exception type. The base of all pykafka exception types.

__weakref__¶: list of weak references to the object (if defined)

exception pykafka.exceptions.LeaderNotAvailable¶

Bases: pykafka.exceptions.ProtocolClientError

This error is thrown if we are in the middle of a leadership election and there is currently no leader for this partition and hence it is unavailable for writes.

exception pykafka.exceptions.MessageSizeTooLarge¶

Bases: pykafka.exceptions.ProtocolClientError

The server has a configurable maximum message size to avoid unbounded memory allocation. This error is thrown if the client attempts to produce a message larger than this maximum.

exception pykafka.exceptions.NoMessagesConsumedError¶

Bases: pykafka.exceptions.KafkaException

Indicates that no messages were returned from a MessageSet

exception pykafka.exceptions.NotCoordinatorForConsumer¶

Bases: pykafka.exceptions.ProtocolClientError

The broker returns this error code if it receives an offset fetch or commit request for a consumer group that it is not a coordinator for.

exception pykafka.exceptions.NotLeaderForPartition¶

Bases: pykafka.exceptions.ProtocolClientError

This error is thrown if the client attempts to send messages to a replica that is not the leader for some partition. It indicates that the client’s metadata is out of date.

exception pykafka.exceptions.OffsetMetadataTooLarge¶

Bases: pykafka.exceptions.ProtocolClientError

If you specify a string larger than configured maximum for offset metadata

exception pykafka.exceptions.OffsetOutOfRangeError¶

Bases: pykafka.exceptions.ProtocolClientError

The requested offset is outside the range of offsets maintained by the server for the given topic/partition.

exception pykafka.exceptions.OffsetRequestFailedError¶

Bases: pykafka.exceptions.KafkaException

Indicates that OffsetRequests for offset resetting failed more times than the configured maximum

exception pykafka.exceptions.OffsetsLoadInProgress¶

Bases: pykafka.exceptions.ProtocolClientError

The broker returns this error code for an offset fetch request if it is still loading offsets (after a leader change for that offsets topic partition).

exception pykafka.exceptions.PartitionOwnedError(partition, *args, **kwargs)¶

Bases: pykafka.exceptions.KafkaException

Indicates a given partition is still owned in Zookeeper.

exception pykafka.exceptions.ProduceFailureError¶

Bases: pykafka.exceptions.KafkaException

Indicates a generic failure in the producer

exception pykafka.exceptions.ProducerQueueFullError¶

Bases: pykafka.exceptions.KafkaException

Indicates that one or more of the AsyncProducer’s internal queues contain at least max_queued_messages messages

exception pykafka.exceptions.ProducerStoppedException¶

Bases: pykafka.exceptions.KafkaException

Raised when the Producer is used while not running