Merge "python-kafka's KafkaClient does an async connect in a loop. We…

… need to shorten the timeout so that alarmgen will not get stuck. Closes-Bug:1587680" into R3.0
Juniper · Jun 1, 2016 · 233878a · 233878a
2 parents de9e554 + 092b1db
commit 233878a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/opserver/partition_handler.py b/src/opserver/partition_handler.py
@@ -571,7 +571,7 @@ def _run(self):
                     gevent.sleep(2)
                     pause = False
                 self._logger.error("New KafkaClient %s" % self._topic)
-                self._kfk = KafkaClient(self._brokers , "kc-" + self._topic)
+                self._kfk = KafkaClient(self._brokers , "kc-" + self._topic, timeout=1)
                 try:
                     consumer = SimpleConsumer(self._kfk, self._group, self._topic, buffer_size = 4096*4, max_buffer_size=4096*32)
                     #except: