From efcf58b84214aeda6cf79319f182407cde7833a6 Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Tue, 6 May 2014 21:24:15 -0700 Subject: Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns --- kafka/common.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'kafka/common.py') diff --git a/kafka/common.py b/kafka/common.py index d288b89..d515532 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -121,11 +121,16 @@ class StaleControllerEpochError(BrokerResponseError): message = 'STALE_CONTROLLER_EPOCH' -class OffsetMetadataTooLarge(BrokerResponseError): +class OffsetMetadataTooLargeError(BrokerResponseError): errno = 12 message = 'OFFSET_METADATA_TOO_LARGE' +class StaleLeaderEpochCodeError(BrokerResponseError): + errno = 13 + message = 'STALE_LEADER_EPOCH_CODE' + + class KafkaUnavailableError(KafkaError): pass @@ -178,7 +183,8 @@ kafka_errors = { 9 : ReplicaNotAvailableError, 10 : MessageSizeTooLargeError, 11 : StaleControllerEpochError, - 12 : OffsetMetadataTooLarge, + 12 : OffsetMetadataTooLargeError, + 13 : StaleLeaderEpochCodeError, } def check_error(response): -- cgit v1.2.1