add new exceptions to error code map

Parsely · Apr 27, 2015 · 6834731 · 6834731
1 parent 134e069
commit 6834731
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pykafka/exceptions.py b/pykafka/exceptions.py
@@ -144,5 +144,8 @@ class NotCoordinatorForConsumer(ProtocolClientError):
                 NotLeaderForPartition,
                 RequestTimedOut,
                 MessageSizeTooLarge,
-                OffsetMetadataTooLarge)
+                OffsetMetadataTooLarge,
+                OffsetsLoadInProgress,
+                ConsumerCoordinatorNotAvailable,
+                NotCoordinatorForConsumer)
 )