search

apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.28k stars 409 forks source link

push consumer may have concurrency issue for the map which used by control the goroutine numbers #1146

Open absolute8511 opened 1 month ago

absolute8511 commented 1 month ago

BUG REPORT

  1. Please describe the issue you observed:

    • push consumer may have concurrency issue for the map crCh map[string]chan struct{}

  2. Please tell us about your environment:

the newest go client version

  1. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):