Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Memory leak in the confluent kafka producer #1030

Closed
yanmxa opened this issue Apr 1, 2024 · 0 comments · Fixed by #1031
Closed

Memory leak in the confluent kafka producer #1030

yanmxa opened this issue Apr 1, 2024 · 0 comments · Fixed by #1031

Comments

@yanmxa
Copy link
Contributor

yanmxa commented Apr 1, 2024

@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: confluentinc/confluent-kafka-go#1043, confluentinc/confluent-kafka-go#578

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant