Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns

1 files changed, 8 insertions, 2 deletions

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):