apache / rocketmq-client-go

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

topic with namespace and retry is block #933

Closed 0daypwn closed 1 year ago

0daypwn commented 2 years ago

BUG REPORT

  1. Please describe the issue you observed:

    • What did you do (The steps to reproduce)?

    • What did you expect to see?

    • What did you see instead?

      923 add some code.

      example. topic name is test-topic when do subscribe, pc.crCh only add key: test-topic it does not include: a. topic with namespace. topic name is namespace%test-topic b. consumer retry topic. %RETRY%group

    when consumer, because pc.crCh does not include topic, it will block.

  2. Please tell us about your environment:

    • What is your OS?

    • What is your client version?

    • What is your RocketMQ version?

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