arxiv.integration.kinesis.consumer.exceptions module¶

Exceptions raised by BaseConsumer.

exception arxiv.integration.kinesis.consumer.exceptions.CheckpointError[source]¶

Checkpointing failed.

exception arxiv.integration.kinesis.consumer.exceptions.ConfigurationError[source]¶

There was a problem with the configuration.

exception arxiv.integration.kinesis.consumer.exceptions.KinesisRequestFailed[source]¶

Raised when a Kinesis request failed permanently.

exception arxiv.integration.kinesis.consumer.exceptions.RestartProcessing[source]¶

Something happened that requires a restart.

exception arxiv.integration.kinesis.consumer.exceptions.StopProcessing[source]¶

Gracefully stopped processing upon unrecoverable error.

exception arxiv.integration.kinesis.consumer.exceptions.StreamNotAvailable[source]¶

Could not find or connect to the stream.

arXiv base