1 files changed, 16 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py
index 253137c..173fc82 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -93,6 +93,22 @@ class KafkaError(RuntimeError):
     pass
 
 
+class IllegalStateError(KafkaError):
+    pass
+
+
+class RetriableError(KafkaError):
+    pass
+
+
+class DisconnectError(KafkaError):
+    pass
+
+
+class CorrelationIdError(KafkaError):
+    pass
+
+
 class BrokerResponseError(KafkaError):
     errno = None
     message = None