[ISSUE #9115] Optimize the broker's reverse notification for consumerId change

[yx9o]

Fixes #9115 .

[codecov-commenter]

Codecov Report

Attention: Patch coverage is 57.14286% with 9 lines in your changes missing coverage. Please review.

Project coverage is 47.97%. Comparing base (e0db654) to head (65779b2).
Report is 8 commits behind head on develop.

Files with missing lines	Patch %	Lines
...roker/client/DefaultConsumerIdsChangeListener.java	57.14%	5 Missing and 4 partials ⚠️

Additional details and impacted files

@@              Coverage Diff              @@
##             develop    #9116      +/-   ##
=============================================
- Coverage      48.09%   47.97%   -0.12%     
+ Complexity     12077    12050      -27     
=============================================
  Files           1320     1320              
  Lines          92840    92867      +27     
  Branches       11898    11900       +2     
=============================================
- Hits           44654    44557      -97     
- Misses         42694    42797     +103     
- Partials        5492     5513      +21     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[qianye1001]

1. task1 has already done notification
2. task2 try interrupt task1 and update map
3. task1 remove group in map

if so, task2 will never be interrupted, but it is better than now

[yx9o]

1. task1 has already done notification
2. task2 try interrupt task1 and update map
3. task1 remove group in map

if so, task2 will never be interrupted, but it is better than now

Hi, thank you for your review. I added the atomic check here. Please help review it again. Thank you.

[qianye1001]

LGTM

[Koado]

What is the role of channels in NotifyTaskControl?

[yx9o]

Ensure that when a new notification task arrives, the channels in the old notification task are no longer notified.

[Koado]

I understand that this is controlled by the interrupted flag? once the interrupted flag is true, the for loop will be break.