Fails for kafka not available case

Author: Sudev Ambadi

src/KafkaHandler.py

@@ -14,10 +14,10 @@ def __init__(self, hosts_list, topic, batch_size, key=None):
     def emit(self, record):
         # drop kafka logging to avoid infinite recursion
         # Or should I write them to a file ? (Grr.. there are too many of them too, so ignore) 
-        if record.name == 'kafka':
+        if record.name ==  'kafka':
             return
         try:
-            # use default formatting and then byte encode it
+            # use default formatting, this can be overiden by goibibo buckter format
             msg = self.format(record)
             msg = bytes(msg)
             # Keyed messages should be produced when ordering of message is important

test/kafka_dead.py

@@ -0,0 +1,29 @@
+import logging
+import pdb 
+import time 
+import numpy 
+import sys
+sys.path.append('../src')
+import KafkaHandler as kl
+
+logger = logging.getLogger('spam_application')
+logger.setLevel(logging.DEBUG)
+
+# Add the log message handler to the logger
+# Lets give wrong kafka url and try what happens 
+handler = kl.KafkaLoggingHandler(hosts_list="10.70.45.47:9092", topic= "testLogger", batch_size=100, key="Hello")
+
+logger.addHandler(handler)
+
+latency = []
+# Log some messages
+for i in range(200):
+    t = time.time()
+    logger.info('i = %d' % i)
+    logger.debug('i = %d' % i)
+    latency.append(time.time() - t)
+
+nl = numpy.array(latency)
+print(numpy.mean(nl))
+print(numpy.std(nl))
+time.sleep(20)