Prerequisites

• I have searched issues to ensure it has not already been reported

Description

Hello,
I have a memory leak in my project and I've detected it inside Kafkaflow when my kafka broker throws a connection exception. I'm using synchronous version of "Produce()" and I think the TaskCompletionSource used in this method is not complete because Confluent.Kafka is throwing an exception that is not catched.

I've seen this in InternalProduce method:

And I do this change to try to fix and I don't have the problem anymore:

Steps to reproduce

I have the problem with kafka in aws, I didn't know how to reproduce in my local.

Expected behavior

End Produce method and show error in DeliveryReport

Actual behavior

TaskCompletionSource not complete and not release resources

KafkaFlow version

3.0.10