From 0d4e28f05efd2a1e39558ab2516e054b97297900 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 10 Oct 2017 10:15:40 -0700 Subject: Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230) --- kafka/errors.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'kafka/errors.py') diff --git a/kafka/errors.py b/kafka/errors.py index 35f9d94..c72455a 100644 --- a/kafka/errors.py +++ b/kafka/errors.py @@ -33,7 +33,11 @@ class NodeNotReadyError(KafkaError): retriable = True -class CorrelationIdError(KafkaError): +class KafkaProtocolError(KafkaError): + retriable = True + + +class CorrelationIdError(KafkaProtocolError): retriable = True -- cgit v1.2.1