cli fixups: producer stdin/eof support; consumer unused e var

Author: dpkp

kafka/cli/consumer/__init__.py

@@ -82,7 +82,7 @@ def run_cli(args=None):
     except KafkaError as e:
         logger.error(e)
         return 1
-    except Exception as e:
+    except Exception:
         logger.exception('Error!')
         return 1
     finally:

kafka/cli/producer/__init__.py

@@ -2,6 +2,7 @@
 
 import argparse
 import logging
+import sys
 
 from kafka import KafkaProducer
 
@@ -73,7 +74,12 @@ def log_result(res_or_err):
 
     try:
         while True:
-            value = input_py23()
+            try:
+                value = input_py23()
+            except EOFError:
+                value = sys.stdin.read().rstrip('\n')
+                if not value:
+                    return 0
             producer.send(config.topic, value=value.encode(config.encoding)).add_both(log_result)
     except KeyboardInterrupt:
         logger.info('Bye!')