Searched refs:AsyncProducerQueueFull (Results 1 – 3 of 3) sorted by relevance
501 class AsyncProducerQueueFull(KafkaError): class503 super(AsyncProducerQueueFull, self).__init__(*args)
13 AsyncProducerQueueFull, FailedPayloadsError, NotLeaderForPartitionError)83 with self.assertRaises(AsyncProducerQueueFull):
19 RequestTimedOutError, AsyncProducerQueueFull, UnknownError,419 raise AsyncProducerQueueFull(