Closed yanmxa closed 1 month ago
@embano1 I just found a memory leak in the confluent kafka protocol Sender. I apologize for overlooking this issue in the initial version.
Sender
The producer should fetch the event from the producer.Events() chan. Otherwise, the events chan will eventually fill up.
producer.Events()
Reference: https://github.com/confluentinc/confluent-kafka-go/issues/1043, https://github.com/confluentinc/confluent-kafka-go/issues/578
@embano1 I just found a memory leak in the confluent kafka protocol
Sender. I apologize for overlooking this issue in the initial version.The producer should fetch the event from the
producer.Events()chan. Otherwise, the events chan will eventually fill up.Reference: https://github.com/confluentinc/confluent-kafka-go/issues/1043, https://github.com/confluentinc/confluent-kafka-go/issues/578