We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cee4d17 commit 21b00c3Copy full SHA for 21b00c3
kafka/producer/kafka.py
@@ -464,7 +464,6 @@ def close(self, timeout=None):
464
assert timeout >= 0
465
466
log.info("Closing the Kafka producer with %s secs timeout.", timeout)
467
- #first_exception = AtomicReference() # this will keep track of the first encountered exception
468
invoked_from_callback = bool(threading.current_thread() is self._sender)
469
if timeout > 0:
470
if invoked_from_callback:
0 commit comments