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: ...