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

[Master] Goroutine leaks when consumer restart frequently #614

Closed
maixiaohai opened this issue Mar 8, 2021 · 1 comment · Fixed by #642
Closed

[Master] Goroutine leaks when consumer restart frequently #614

maixiaohai opened this issue Mar 8, 2021 · 1 comment · Fixed by #642
Labels
enhancement New feature or request

Comments

@maixiaohai
Copy link
Contributor

BUG REPORT

  1. Please describe the issue you observed:

    • What did you do (The steps to reproduce)?
      We have a logic to manage different pushConsumer as task. So we need to restart pushConsumer with same subscription in the same process.
    • What did you expect to see?
      start consumer with no new message come, the sleep 3 second, shutdown the consumer.The goroutine number not increase with the start and shutdown.
    • What did you see instead?
      The number of goroutine increase.

image

  1. Please tell us about your environment:

    • What is your OS?
      Centos 7
    • What is your client version?
      v2.1.0-rc5
    • What is your RocketMQ version?
      v4.7.0 / v4.8.0
  2. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):
    msgCh should be closed when consumer shutdown?

@maixiaohai
Copy link
Contributor Author

After fix
image

@maixiaohai maixiaohai added the enhancement New feature or request label Jun 17, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
1 participant