You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/06/07 08:43:33 UTC
[GitHub] [rocketmq] 6U-U9 opened a new pull request, #4428: [Issue #4427] Implement transaction message escape of RIP 32
6U-U9 opened a new pull request, #4428:
URL: https://github.com/apache/rocketmq/pull/4428
**Make sure set the target branch to `develop`**
**PS: Target branch is 5.0.0-beta cause there is no EscapeBridge in develop branch**
## What is the purpose of the change
Implement transaction message escape of RIP 32
Issue #4427
## Brief changelog
Design can be found in Issue #4427 .
## Verifying this change
Test TransactionSlaveActingMasterIT added to Test Module.
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`.
- [x] Make sure there is a [Github issue](https://github.com/apache/rocketmq/issues) filed for the change (usually before you start working on it). Trivial changes like typos do not require a Github issue. Your pull request should address just this issue, without pulling in other changes - one PR resolves one issue.
- [x] Format the pull request title like `[ISSUE #123] Fix UnknownException when host config not exist`. Each commit in the pull request should have a meaningful subject line and body.
- [x] Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
- [x] Write necessary unit-test(over 80% coverage) to verify your logic correction, more mock a little better when cross module dependency exist. If the new feature or significant change is committed, please remember to add integration-test in [test module](https://github.com/apache/rocketmq/tree/master/test).
- [x] Run `mvn -B clean apache-rat:check findbugs:findbugs checkstyle:checkstyle` to make sure basic checks pass. Run `mvn clean install -DskipITs` to make sure unit-test pass. Run `mvn clean test-compile failsafe:integration-test` to make sure integration-test pass.
- [ ] If this contribution is large, please file an [Apache Individual Contributor License Agreement](http://www.apache.org/licenses/#clas).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 6U-U9 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
6U-U9 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1153232642
> `org.apache.rocketmq.broker.transaction.queue.DefaultTransactionalMessageCheckListener#resolveDiscardMsg` handles transactional messages that should not be processed any more, what about normal transactional messages on the slave broker in acting master mode? Furthermore, what happened if the broken master recovered?
When dealing with transaction message normally, **transactionalMessageCheckService** checks half messages in **RMQ_SYS_TRANS_HALF_TOPIC**, calls **putBackHalfMsgQueue** to rewrite messages still need to check back to message queue of **RMQ_SYS_TRANS_HALF_TOPIC** , and updates consume offset.
When slave acts master, its **transactionalMessageCheckService** will start, but its **EndTransactionProcessor** will not accept any message tries to end a transaction such as commit or rollback. The running **transactionalMessageCheckService** will check transaction message and send any message needs check to a living master. **RMQ_SYS_TRANS_HALF_TOPIC** is also a topic not allowed to send in topic validator.So first wrap them in their origin topic with transaction check time, and send it to other master broker. Messages will bring its properties, such as **PROPERTY_TRANSACTION_CHECK_TIMES** , so master broker received these message is not going to check the transaction message for another **TRANS_CHECK_MAX_TIME**.
When the master broker recovers, it will be in pre-online progress before it is launched. It reversely obtains the metadata of the slave, especially the consumer offset of **RMQ_SYS_TRANS_HALF_TOPIC**. Thus the recovered master broker will not check the message which has escaped.
在正常处理事务消息时，**transactionalMessageCheckService**检查半消息队列**RMQ_SYS_TRANS_HALF_TOPIC**中的半消息，并调用**putBackHalfMsgQueue**将检查到的并且仍需进行检查的消息写入半消息队列**RMQ_SYS_TRANS_HALF_TOPIC**中，并更新消费位置。
Slave代理Master时，**transactionalMessageCheckService**将启动。**transactionalMessageCheckService**将检查到的事务消息通过EscapeBridge向其他的Master逃逸。逃逸过程中为了避免半消息**RMQ_SYS_TRANS_HALF_TOPIC**不可写的限制，首先将半消息用原Topic包装，此时消息仍携带**PROPERTY_TRANSACTION_CHECK_TIMES**等属性，然后再投递到远程主节点上。收到消息的主节点将消息放入半消息队列**RMQ_SYS_TRANS_HALF_TOPIC**等待检查。
在主节点恢复后，通过预上线机制获取从节点的**RMQ_SYS_TRANS_HALF_TOPIC**队列的消费位点，更新主节点自己的**RMQ_SYS_TRANS_HALF_TOPIC**队列的消费位点，将不再检查已经逃逸的事务消息。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 6U-U9 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
6U-U9 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150599797
> <img alt="image" width="678" src="https://user-images.githubusercontent.com/58988019/172747848-4223f672-4e7a-4594-8fc6-c98a60a9f59d.png">
>
> Pls check why the test failed.
I didn't meet this error when running test. And also you can find the test passed in the Travis CI - Pull Request build detail, line 3086.
[https://app.travis-ci.com/github/apache/rocketmq/jobs/572672220](url)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] coveralls commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
coveralls commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150624253
[](https://coveralls.io/builds/49867043)
Coverage decreased (-0.02%) to 47.287% when pulling **55e7384e77bfc5525fafcf056af51fd425c2eb29 on 6U-U9:5.0.0-beta** into **42e5d734eec8ed662fb6c9b06ff1faf615559653 on apache:5.0.0-beta**.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1588273984
This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale, please leave a comment in this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] coveralls commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
coveralls commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150624250
[](https://coveralls.io/builds/49867043)
Coverage decreased (-0.02%) to 47.287% when pulling **55e7384e77bfc5525fafcf056af51fd425c2eb29 on 6U-U9:5.0.0-beta** into **42e5d734eec8ed662fb6c9b06ff1faf615559653 on apache:5.0.0-beta**.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] hzh0425 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
hzh0425 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150604778
yep, you can re trigger the ci
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] closed pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
URL: https://github.com/apache/rocketmq/pull/4428
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] hzh0425 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
hzh0425 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150587654
<img width="678" alt="image" src="https://user-images.githubusercontent.com/58988019/172747848-4223f672-4e7a-4594-8fc6-c98a60a9f59d.png">
Pls check why the test failed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] github-actions[bot] commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1595502746
This PR was closed because it has been inactive for 3 days since being marked as stale.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 6U-U9 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
6U-U9 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150619769
> It's a bit puzzling to process message escape when processing messages that should be discarded. Hopefully you could provide more details about your design.
Actually it's like the remote message escape mechanism. When discarding messages, Rocket MQ puts messages into **RMQ_SYS_TRANS_CHECK_MAX_TIME_TOPIC**, which is a not allowed to send topic in topic validator. For the remote escape of these messages, first wrap them in their origin topic with **transaction check time**, and send it to other master broker. As messages bring **PROPERTY_TRANSACTION_CHECK_TIMES** with them, master broker received these message first put them into half topic queue and discard them in next check.
应丢弃的消息逃逸机制和正常消息的逃逸机制相似。为了避免**RMQ_SYS_TRANS_CHECK_MAX_TIME_TOPIC**远程不可写的限制，首先将半消息用原Topic包装，此时消息仍携带**PROPERTY_TRANSACTION_CHECK_TIMES**属性，然后再投递到远程主节点上。收到消息的主节点将消息放入半消息队列**RMQ_SYS_TRANS_HALF_TOPIC**等待检查，在下一次检查中，将消息丢弃。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] caigy commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
caigy commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1153149043
`org.apache.rocketmq.broker.transaction.queue.DefaultTransactionalMessageCheckListener#resolveDiscardMsg` handles transactional messages that should not be processed any more, what about normal transactional messages on the slave broker in acting master mode?
Furthermore, what happened if the broken master recovered?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] hzh0425 commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
hzh0425 commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1148439130
Good job, But does your contribution overlap with this issue? https://github.com/apache/rocketmq/issues/4408
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] codecov-commenter commented on pull request #4428: [Issue #4427] Implement transaction message escape of RIP 32
Posted by GitBox <gi...@apache.org>.
codecov-commenter commented on PR #4428:
URL: https://github.com/apache/rocketmq/pull/4428#issuecomment-1150620874
# [Codecov](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
> Merging [#4428](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (55e7384) into [5.0.0-beta](https://codecov.io/gh/apache/rocketmq/commit/42e5d734eec8ed662fb6c9b06ff1faf615559653?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (42e5d73) will **decrease** coverage by `0.07%`.
> The diff coverage is `10.25%`.
```diff
@@ Coverage Diff @@
## 5.0.0-beta #4428 +/- ##
================================================
- Coverage 43.14% 43.07% -0.08%
+ Complexity 6064 6055 -9
================================================
Files 801 801
Lines 57087 57123 +36
Branches 7805 7811 +6
================================================
- Hits 24633 24607 -26
- Misses 29231 29287 +56
- Partials 3223 3229 +6
```
| [Impacted Files](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | Coverage Δ | |
|---|---|---|
| [.../apache/rocketmq/broker/failover/EscapeBridge.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvZmFpbG92ZXIvRXNjYXBlQnJpZGdlLmphdmE=) | `11.62% <0.00%> (+1.47%)` | :arrow_up: |
| [...ion/AbstractTransactionalMessageCheckListener.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvdHJhbnNhY3Rpb24vQWJzdHJhY3RUcmFuc2FjdGlvbmFsTWVzc2FnZUNoZWNrTGlzdGVuZXIuamF2YQ==) | `65.90% <0.00%> (-4.83%)` | :arrow_down: |
| [...ueue/DefaultTransactionalMessageCheckListener.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvdHJhbnNhY3Rpb24vcXVldWUvRGVmYXVsdFRyYW5zYWN0aW9uYWxNZXNzYWdlQ2hlY2tMaXN0ZW5lci5qYXZh) | `76.47% <0.00%> (-7.91%)` | :arrow_down: |
| [...saction/queue/TransactionalMessageServiceImpl.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvdHJhbnNhY3Rpb24vcXVldWUvVHJhbnNhY3Rpb25hbE1lc3NhZ2VTZXJ2aWNlSW1wbC5qYXZh) | `49.37% <0.00%> (-0.63%)` | :arrow_down: |
| [.../transaction/queue/TransactionalMessageBridge.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvdHJhbnNhY3Rpb24vcXVldWUvVHJhbnNhY3Rpb25hbE1lc3NhZ2VCcmlkZ2UuamF2YQ==) | `67.82% <13.79%> (-8.75%)` | :arrow_down: |
| [...apache/rocketmq/broker/longpolling/PopRequest.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvbG9uZ3BvbGxpbmcvUG9wUmVxdWVzdC5qYXZh) | `31.03% <0.00%> (-13.80%)` | :arrow_down: |
| [...ava/org/apache/rocketmq/filter/util/BitsArray.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZmlsdGVyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9maWx0ZXIvdXRpbC9CaXRzQXJyYXkuamF2YQ==) | `59.82% <0.00%> (-2.57%)` | :arrow_down: |
| [...va/org/apache/rocketmq/logging/inner/Appender.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-bG9nZ2luZy9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvcm9ja2V0bXEvbG9nZ2luZy9pbm5lci9BcHBlbmRlci5qYXZh) | `30.33% <0.00%> (-2.25%)` | :arrow_down: |
| [...a/org/apache/rocketmq/filter/util/BloomFilter.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZmlsdGVyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9maWx0ZXIvdXRpbC9CbG9vbUZpbHRlci5qYXZh) | `59.13% <0.00%> (-2.16%)` | :arrow_down: |
| [...rocketmq/client/impl/factory/MQClientInstance.java](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-Y2xpZW50L3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9jbGllbnQvaW1wbC9mYWN0b3J5L01RQ2xpZW50SW5zdGFuY2UuamF2YQ==) | `45.64% <0.00%> (-1.39%)` | :arrow_down: |
| ... and [9 more](https://codecov.io/gh/apache/rocketmq/pull/4428/diff?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Last update [42e5d73...55e7384](https://codecov.io/gh/apache/rocketmq/pull/4428?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org