From 8c91d53762058d719a2354956f9f4c92d4f1b953 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 14 Mar 2025 16:39:26 -0700 Subject: [PATCH] Raise immediate error on producer.send after close --- kafka/producer/kafka.py | 1 + 1 file changed, 1 insertion(+) diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index b97983a78..b8ace0fc1 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -594,6 +594,7 @@ def send(self, topic, value=None, key=None, headers=None, partition=None, timest KafkaTimeoutError: if unable to fetch topic metadata, or unable to obtain memory buffer prior to configured max_block_ms """ + assert not self._closed, 'KafkaProducer already closed!' assert value is not None or self.config['api_version'] >= (0, 8, 1), ( 'Null messages require kafka >= 0.8.1') assert not (value is None and key is None), 'Need at least one: key or value'