Skip to content

Commit b60a266

Browse files
authored
Raise immediate error on producer.send after close (#2542)
1 parent ed4ecee commit b60a266

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

kafka/producer/kafka.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -594,6 +594,7 @@ def send(self, topic, value=None, key=None, headers=None, partition=None, timest
594594
KafkaTimeoutError: if unable to fetch topic metadata, or unable
595595
to obtain memory buffer prior to configured max_block_ms
596596
"""
597+
assert not self._closed, 'KafkaProducer already closed!'
597598
assert value is not None or self.config['api_version'] >= (0, 8, 1), (
598599
'Null messages require kafka >= 0.8.1')
599600
assert not (value is None and key is None), 'Need at least one: key or value'

0 commit comments

Comments
 (0)