From 4f63601ba60cfd8569fc982d3d9d0e559bf5309a Mon Sep 17 00:00:00 2001
From: Thanasis Mattas <thanasismatt@gmail.com>
Date: Sat, 18 Apr 2026 22:55:23 +0200
Subject: [PATCH] fix: add missing Producer.close() stub

---
 src/confluent_kafka/cimpl.pyi | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/confluent_kafka/cimpl.pyi b/src/confluent_kafka/cimpl.pyi
index e0e92a93e..e9a5a5df8 100644
--- a/src/confluent_kafka/cimpl.pyi
+++ b/src/confluent_kafka/cimpl.pyi
@@ -374,6 +374,7 @@ class Producer:
     ) -> int: ...
     def poll(self, timeout: float = -1) -> int: ...
     def flush(self, timeout: float = -1) -> int: ...
+    def close(self) -> None: ...
     def purge(self, in_queue: bool = True, in_flight: bool = True, blocking: bool = True) -> None: ...
     def abort_transaction(self, timeout: float = -1) -> None: ...
     def begin_transaction(self) -> None: ...