diff options
Diffstat (limited to 'kafka/errors.py')
| -rw-r--r-- | kafka/errors.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/errors.py b/kafka/errors.py index c70853c..f4c8740 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -447,7 +447,7 @@ class FailedPayloadsError(KafkaError): self.payload = payload -class ConnectionError(KafkaError): +class KafkaConnectionError(KafkaError): retriable = True invalid_metadata = True @@ -517,13 +517,13 @@ def check_error(response): RETRY_BACKOFF_ERROR_TYPES = ( KafkaUnavailableError, LeaderNotAvailableError, - ConnectionError, FailedPayloadsError + KafkaConnectionError, FailedPayloadsError ) RETRY_REFRESH_ERROR_TYPES = ( NotLeaderForPartitionError, UnknownTopicOrPartitionError, - LeaderNotAvailableError, ConnectionError + LeaderNotAvailableError, KafkaConnectionError ) |