diff --git a/kafka/errors.py b/kafka/errors.py index bea1c814f..0c572890c 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -47,7 +47,7 @@ class KafkaConnectionError(KafkaError): class KafkaProtocolError(KafkaError): - retriable = True + pass class CorrelationIdError(KafkaProtocolError):