From 18fdddf37f552cef72bd7714c1aacc8a35a5f190 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Wed, 13 Aug 2014 11:51:48 -0700
Subject: Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a
 test

---
 kafka/common.py | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'kafka/common.py')

diff --git a/kafka/common.py b/kafka/common.py
index 209754b..907e128 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -135,6 +135,10 @@ class KafkaUnavailableError(KafkaError):
     pass
 
 
+class KafkaTimeoutError(KafkaError):
+    pass
+
+
 class LeaderUnavailableError(KafkaError):
     pass
 
-- 
cgit v1.2.1