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.

Sign up for GitHub

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

Jump to bottom

[Enhancement] Let PushConsumer client aware of message queue assignment change #7547

Closed
1 task done
lizhanhui opened this issue Nov 10, 2023 · 0 comments · Fixed by #7548
Closed
1 task done

[Enhancement] Let PushConsumer client aware of message queue assignment change #7547

lizhanhui opened this issue Nov 10, 2023 · 0 comments · Fixed by #7548
Labels
type/enhancement

Comments

@lizhanhui
Copy link
Contributor

Before Creating the Enhancement Request

  • I have confirmed that this should be classified as an enhancement rather than a bug/feature.

Summary

Allowing consumer client is being aware of the message queue assignment change is essential to log key events and fix flaky integration tests.

Motivation

Allowing consumer client is being aware of the message queue assignment change is essential to log key events and fix flaky integration tests.

Describe the Solution You'd Like

Expose rebalance results via existing MessageQueueListener API

Describe Alternatives You've Considered

N/A

Additional Context

No response
@lizhanhui lizhanhui mentioned this issue Nov 10, 2023
Merged
lizhanhui added a commit that referenced this issue Nov 13, 2023
@lizhanhui
[ISSUE #7547] Let consumer be aware of message queue assignment change (
15d32db 
#7548)

* let consumer be aware of message queue assignment change

Signed-off-by: Li Zhanhui <[email protected]>

* add unit test for DefaultMQPushConsumer#setMessageQueueListener

Signed-off-by: Li Zhanhui <[email protected]>

* fix: bazel build warnings

Signed-off-by: Zhanhui Li <[email protected]>

* fix: set MixCommitlogTest test size as medium

Signed-off-by: Zhanhui Li <[email protected]>

* allow cache bazel test results

Signed-off-by: Li Zhanhui <[email protected]>

* fix code style issue by removing unused imports

Signed-off-by: Li Zhanhui <[email protected]>

* fix #7552

Signed-off-by: Zhanhui Li <[email protected]>

---------

Signed-off-by: Li Zhanhui <[email protected]>
Signed-off-by: Zhanhui Li <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
type/enhancement
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

[ISSUE #7547] Let consumer be aware of message queue assignment change apache/rocketmq
1 participant
@lizhanhui