diff --git a/faststream/__about__.py b/faststream/__about__.py index f728897053..2b278138dd 100644 --- 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 index 42e2e20f0e..054c3d6d39 100644 --- 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: