apache / rocketmq-client-go

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

[ISSUE #945]init crCh after topic with namespace to avoid consumption blocked. #944

Closed NeonToo closed 2 years ago

NeonToo commented 2 years ago

…se consumption blocked; opt on log

What is the purpose of the change

close #945

Brief changelog

XX

Verifying this change

XXXX

Follow this checklist to help us incorporate your contribution quickly and easily. Notice, it would be helpful if you could finish the following 5 checklist(the last one is not necessary)before request the community to review your PR.

0daypwn commented 2 years ago

933 #934

It should be the same problem.Retry topic also needs to be considered.

codecov-commenter commented 2 years ago

Codecov Report

Merging #944 (003b83f) into master (8011561) will increase coverage by 0.04%. The diff coverage is 46.66%.

@@            Coverage Diff             @@
##           master     #944      +/-   ##
==========================================
+ Coverage   23.61%   23.65%   +0.04%     
==========================================
  Files          52       52              
  Lines        7170     7179       +9     
==========================================
+ Hits         1693     1698       +5     
- Misses       5247     5251       +4     
  Partials      230      230              
Impacted Files Coverage Δ
consumer/consumer.go 17.61% <0.00%> (ø)
internal/client.go 0.17% <0.00%> (-0.01%) :arrow_down:
internal/constants.go 0.00% <0.00%> (ø)
consumer/push_consumer.go 13.29% <100.00%> (+0.48%) :arrow_up:

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more