From b260b356b23802a595336c554d6ea044c9be0a79 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Mon, 1 Sep 2014 16:41:18 -0700
Subject: [PATCH] Raise UnknownTopicOrPartitionError immediately in
 ensure_topic_exists -- server is not auto-creating

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

diff --git a/kafka/client.py b/kafka/client.py
index 3b9aba9..4d79b41 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -257,6 +257,10 @@ class KafkaClient(object):
                 self.load_metadata_for_topics(topic)
             except LeaderNotAvailableError:
                 pass
+            except UnknownTopicOrPartitionError:
+                # Server is not configured to auto-create
+                # retrying in this case will not help
+                raise
             time.sleep(.5)
 
     def load_metadata_for_topics(self, *topics):