summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2019-05-23 23:19:29 -0700
committerJeff Widman <jeff@jeffwidman.com>2019-05-23 23:19:29 -0700
commit29c1be47297d5855cd733368a3327cd41f032b9e (patch)
treedf52339a5bcf0f4d57a6757ca6b28b7f5744b50c
parent1a0f2973190e2bb60909bfcd28e5ad8e732e918e (diff)
downloadkafka-python-Remove-weird-comment-line.tar.gz
Remove unused/weird comment lineRemove-weird-comment-line
-rw-r--r--kafka/producer/kafka.py1
1 files changed, 0 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 2a306e0..c8f5a72 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -464,7 +464,6 @@ class KafkaProducer(object):
assert timeout >= 0
log.info("Closing the Kafka producer with %s secs timeout.", timeout)
- #first_exception = AtomicReference() # this will keep track of the first encountered exception
invoked_from_callback = bool(threading.current_thread() is self._sender)
if timeout > 0:
if invoked_from_callback: