Add poll in confluent producer to fix BufferError (#1277)

* Add poll in confluent producer to fix BufferError * Bump version
airtai · Mar 1, 2024 · fd644b4 · fd644b4
1 parent 4e61b94
commit fd644b4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/faststream/__about__.py b/faststream/__about__.py
@@ -1,5 +1,5 @@
 """Simple and fast framework to create message brokers based microservices."""
-__version__ = "0.4.5"
+__version__ = "0.4.6"
 
 
 INSTALL_YAML = """

diff --git a/faststream/confluent/client.py b/faststream/confluent/client.py
@@ -244,6 +244,7 @@ async def send(
             # on_delivery=ack,
             **kwargs,
         )
+        self.producer.poll(0)
         # return result
 
     def create_batch(self) -> BatchBuilder: