(rocketmq-site) branch new-official-website updated: Add rocketmq dashboard 2.0.0 release note (#691)
This is an automated email from the ASF dual-hosted git repository. dinglei pushed a commit to branch new-official-website in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git The following commit(s) were added to refs/heads/new-official-website by this push: new 5b491d70da Add rocketmq dashboard 2.0.0 release note (#691) 5b491d70da is described below commit 5b491d70da47708e06d4517f1c2a75b493f6a6c0 Author: rongtong AuthorDate: Wed Sep 18 14:19:40 2024 +0800 Add rocketmq dashboard 2.0.0 release note (#691) * Add rocketmq dashboard 2.0.0 release note * Add rocketmq dashboard 2.0.0 release note --- ...09-18-release-notes-rocketmq-dashboard-2.0.0.md | 82 ++ 1 file changed, 82 insertions(+) diff --git a/release-notes/2024-09-18-release-notes-rocketmq-dashboard-2.0.0.md b/release-notes/2024-09-18-release-notes-rocketmq-dashboard-2.0.0.md new file mode 100644 index 00..2d451df787 --- /dev/null +++ b/release-notes/2024-09-18-release-notes-rocketmq-dashboard-2.0.0.md @@ -0,0 +1,82 @@ +--- +title: "Release Notes - Apache RocketMQ Dashboard - Version 2.0.0" +categories: + - Release_Notes +tags: + - RocketMQ_Dashboard + +--- +:::tip Download +* Source: [rocketmq-dashboard-2.0.0-source-release.zip](https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-dashboard/2.0.0/rocketmq-dashboard-2.0.0-source-release.zip) [[PGP](https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-dashboard/2.0.0/rocketmq-dashboard-2.0.0-source-release.zip.asc)] [[SHA512](https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-dashboard/2.0.0/rocketmq-dashboard-2.0.0-source-release.zip.sha512)] + ::: + +Apache RocketMQ Dashboard comes from [apache/rocketmq-externals](https://github.com/apache/rocketmq-externals), this is the first release of RocketMQ Dashboard. + +Below is a summary of the issues addressed in the version 2.0.0 release of RocketMQ Dashboard. For full documentation of the release, a guide to get started, please refer to [Quick Start](https://github.com/apache/rocketmq-dashboard). + +## What's Changed + +### RocketMQ 5.x support +* [ISSUE #195] Support the new metrics of getTransferredTps for rocketmq5.x by @javens0601 in https://github.com/apache/rocketmq-dashboard/pull/197 +* [ISSUE #179] Add topic message type by @guangdashao in https://github.com/apache/rocketmq-dashboard/pull/179 +* [ISSUE #198] Support dashboard v4-v5 switch And query for v5 topic by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/198 +* [ISSUE #204] Support FIFO-Type SubGroup Add、Update and Query For V5 by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/204 +* [ISSUE #207] Proxy Support And ConsumerGroup Enhancement by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/207 +* [ISSUE #208] Supplement UserGuide for RocketMQ 5.0 by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/208 +* [ISSUE #222] Fixed the issue that normal messages in version v4 are not showed by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/222 +* [ISSUE #223] Support Unspecified Topic Add & Update & Query by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/223 +* [ISSUE #229] Support retryMaxTimes field set for consumer group by @1294566108 in https://github.com/apache/rocketmq-dashboard/pull/229 +* [ISSUE #231] 5.x query message detail throw: Failed to query message by Id: xxx by @guyu in https://github.com/apache/rocketmq-dashboard/pull/231 + +### Bug and improvement +* [ISSUE #22]Optimizing the ops page. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/23 +* [ISSUE #10] add react module for dashboard by @RaymondCode in https://github.com/apache/rocketmq-dashboard/pull/12 +* [ISSUE #25]Add filter in consumer list. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/26 +* [ISSUE #33] Update README (use new docker image rocketmq-dashboard 1.0.0) by @StyleTang in https://github.com/apache/rocketmq-dashboard/pull/34 +* [ISSUE #30]Added DLQ message management by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/31 +* [ISSUE #28] add Html router for front-end by @StyleTang in https://github.com/apache/rocketmq-dashboard/pull/29 +* [ISSUE #30]Supports batch resending and batch exporting dlq messages. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/37 +* [ISSUE #38]update rocketmq version. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/39 +* Fix typo by @4ops in https://github.com/apache/rocketmq-dashboard/pull/40 +* [ISSUE #42]Fix deleteSubscriptionGroup not remove consumer offset. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/45 +* [ISSUE #43]Give a tip when no message found with topic + time query. by @zhangjidi2016 in https://github.com/apache/rocketmq-dashboard/pull/44 +* [ISSUE #48] Fix query message bug by @zhiliatom in https:
Re: [PR] Add rocketmq dashboard 2.0.0 release note [rocketmq-site]
ShannonDing merged PR #691: URL: https://github.com/apache/rocketmq-site/pull/691 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] fix typo: PullConsumer -> PushConsumer in Introduction.md [rocketmq-client-go]
yixiak opened a new pull request, #1166: URL: https://github.com/apache/rocketmq-client-go/pull/1166 Fix the error description under PushConsumer interface -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] Expected the service PushConsumerImpl [FAILED] to be RUNNING, but the service has FAILED [rocketmq]
github-actions[bot] commented on issue #6776: URL: https://github.com/apache/rocketmq/issues/6776#issuecomment-2357232766 This issue 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. -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Snapshot Daily Release Automation" failed!
The GitHub Actions job "Snapshot Daily Release Automation" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: d3e5f70979f74349db9c5ebbe3b48ff59b52d677 / kaikoo <42601684+kingkh1...@users.noreply.github.com> [ISSUE #8613] fix start failed when acl2.0 authentication enabled (#8614) Report URL: https://github.com/apache/rocketmq/actions/runs/10913266155 With regards, GitHub Actions via GitBox
(rocketmq-dashboard) branch master updated: [maven-release-plugin] prepare release rocketmq-dashboard-2.0.0
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git The following commit(s) were added to refs/heads/master by this push: new f5c09ac [maven-release-plugin] prepare release rocketmq-dashboard-2.0.0 f5c09ac is described below commit f5c09ac287249cf2a2a0b0c95d7fbca8d8a59a38 Author: RongtongJin AuthorDate: Wed Sep 18 09:57:04 2024 +0800 [maven-release-plugin] prepare release rocketmq-dashboard-2.0.0 --- pom.xml | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pom.xml b/pom.xml index 2b61bfc..5fef290 100644 --- a/pom.xml +++ b/pom.xml @@ -28,14 +28,14 @@ org.apache.rocketmq rocketmq-dashboard jar -1.0.1-SNAPSHOT +2.0.0 rocketmq-dashboard g...@github.com:apache/rocketmq-dashboard.git scm:git:g...@github.com:apache/rocketmq-dashboard.git scm:git:g...@github.com:apache/rocketmq-dashboard.git -1.0.0 +rocketmq-dashboard-2.0.0 @@ -459,7 +459,7 @@ - +
(rocketmq-dashboard) annotated tag rocketmq-dashboard-2.0.0 updated (f5c09ac -> 6889ad8)
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a change to annotated tag rocketmq-dashboard-2.0.0 in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git *** WARNING: tag rocketmq-dashboard-2.0.0 was modified! *** from f5c09ac (commit) to 6889ad8 (tag) tagging f5c09ac287249cf2a2a0b0c95d7fbca8d8a59a38 (commit) replaces rocketmq-dashboard-1.0.0 by RongtongJin on Wed Sep 18 09:57:29 2024 +0800 - Log - [maven-release-plugin] copy for tag rocketmq-dashboard-2.0.0 --- No new revisions were added by this update. Summary of changes:
(rocketmq-dashboard) branch master updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-dashboard.git The following commit(s) were added to refs/heads/master by this push: new e6d4543 [maven-release-plugin] prepare for next development iteration e6d4543 is described below commit e6d454301f0dc4dab75dd2f2ef816256d754b87c Author: RongtongJin AuthorDate: Wed Sep 18 09:57:37 2024 +0800 [maven-release-plugin] prepare for next development iteration --- pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index 5fef290..923afa7 100644 --- a/pom.xml +++ b/pom.xml @@ -28,14 +28,14 @@ org.apache.rocketmq rocketmq-dashboard jar -2.0.0 +2.0.1-SNAPSHOT rocketmq-dashboard g...@github.com:apache/rocketmq-dashboard.git scm:git:g...@github.com:apache/rocketmq-dashboard.git scm:git:g...@github.com:apache/rocketmq-dashboard.git -rocketmq-dashboard-2.0.0 +1.0.0
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 4e6d57b763769d91c585652aee6d28463f670b71 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914307849 With regards, GitHub Actions via GitBox
[I] [Bug] PopMessageProcessor maybe no release lock [rocketmq]
zonghaishang opened a new issue, #8704:
URL: https://github.com/apache/rocketmq/issues/8704
### Before Creating the Bug Report
- [X] I found a bug, not just asking a question, which should be created in
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
- [X] I have searched the [GitHub
Issues](https://github.com/apache/rocketmq/issues) and [GitHub
Discussions](https://github.com/apache/rocketmq/discussions) of this
repository and believe that this is not a duplicate.
- [X] I have confirmed that this bug belongs to the current repository, not
other repositories of RocketMQ.
### Runtime platform environment
mac os
### RocketMQ version
5.3+
### JDK Version
jdk 11
### Describe the Bug
开启 enablePopMessageThreshold 触发popInflightMessageThreshold 可能会导致锁不释放。
```
private CompletableFuture popMsgFromQueue(String topic, String
attemptId, boolean isRetry, GetMessageResult getMessageResult,
PopMessageRequestHeader requestHeader, int queueId, long restNum,
int reviveQid,
Channel channel, long popTime, ExpressionMessageFilter
messageFilter, StringBuilder startOffsetInfo,
StringBuilder msgOffsetInfo, StringBuilder orderCountInfo) {
String lockKey =
topic + PopAckConstants.SPLIT + requestHeader.getConsumerGroup()
+ PopAckConstants.SPLIT + queueId;
boolean isOrder = requestHeader.isOrder();
long offset = getPopOffset(topic, requestHeader.getConsumerGroup(),
queueId, requestHeader.getInitMode(),
false, lockKey, false);
CompletableFuture future = new CompletableFuture<>();
if (!queueLockManager.tryLock(lockKey)) {
restNum =
this.brokerController.getMessageStore().getMaxOffsetInQueue(topic, queueId) -
offset + restNum;
future.complete(restNum);
return future;
}
// 这里的逻辑是已经获取锁了，如果这里 return future; 就会导致锁未释放
// TODO:
// 应该把 future.whenComplete((result, throwable) ->
queueLockManager.unLock(lockKey)); 提前
// 或者 放到 下一行
if (isPopShouldStop(topic, requestHeader.getConsumerGroup(),
queueId)) {
POP_LOGGER.warn("Too much msgs unacked, then stop poping.
topic={}, group={}, queueId={}", topic, requestHeader.getConsumerGroup(),
queueId);
restNum =
this.brokerController.getMessageStore().getMaxOffsetInQueue(topic, queueId) -
offset + restNum;
future.complete(restNum);
return future;
}
try {
future.whenComplete((result, throwable) ->
queueLockManager.unLock(lockKey));
//
```
### Steps to Reproduce
代码走读发现
### What Did You Expect to See?
代码走读发现
### What Did You See Instead?
代码走读发现
### Additional Context
代码走读发现
--
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-unsubscr...@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 0441b0b32100f1efc8eff84ba56119b9905605af / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914427954 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 0441b0b32100f1efc8eff84ba56119b9905605af / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914427956 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 29cbff7129f607a7bfe23647f43446bcc7ebea26 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914600631 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 29cbff7129f607a7bfe23647f43446bcc7ebea26 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914600629 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: ced31fb9f119e134579c2117ee02b807c454eae3 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914643403 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" is working again!
The GitHub Actions job "Build" on rocketmq-clients.git has succeeded. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: ced31fb9f119e134579c2117ee02b807c454eae3 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914643402 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 394e7e2beeb23c43c52b52cc17e3046698680b57 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914713233 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 79203d618b020fcb89af10644a003b8d7e72c219 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914883609 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 99f5824968de52f1089009ca21b3843da41f17ba / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914898667 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 366dccb7198d3713f4350985d79cfd5566383bc3 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914924821 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 7c968bd2d3f50823324a675d79afeee4d208e113 / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914958381 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: fe2b6c17a9cad958d508ff43ede8aec44712a97f / tsaitsung-han.tht Fix codespell and license issue Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10914787079 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: cec08d08b45be05b1b7d8bd81a8fa3713dafa7cd / tsaitsung-han.tht Add ignore words for codespell check Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10915056292 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" failed!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 33c6ac215ba0ca344c2c4f926c64c5ab07d6ea0c / tsaitsung-han.tht Add ignore words for codespell check Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10915068997 With regards, GitHub Actions via GitBox
Re: [I] Admin Tool 页面的命令和参数都不全 [rocketmq-site]
RongtongJin commented on issue #690: URL: https://github.com/apache/rocketmq-site/issues/690#issuecomment-2357422728 可以帮忙提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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Add quickstartWithHelmInKubernetesFor5.0 [rocketmq-site]
RongtongJin closed issue #684: Add quickstartWithHelmInKubernetesFor5.0 URL: https://github.com/apache/rocketmq-site/issues/684 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "CodeSpell Check" is working again!
The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has succeeded. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 4b10cc7f198286477e75f7b39f618c09159a7944 / tsaitsung-han.tht Add ignore words for codespell check Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10915082439 With regards, GitHub Actions via GitBox
[PR] Add rocketmq dashboard 2.0.0 release note [rocketmq-site]
RongtongJin opened a new pull request, #691: URL: https://github.com/apache/rocketmq-site/pull/691 Please do not create a Pull Request without creating an issue first. ## What is the purpose of the change Add rocketmq dashboard 2.0.0 release note ## Brief changelog Add rocketmq dashboard 2.0.0 release note ## Verifying this change Follow this checklist to help us incorporate your contribution quickly and easily: - [x] Make sure there is a Github issue 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. - [ ] 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. - [ ] Write a pull request description that is detailed enough to understand what the pull request does, how, and why. - [ ] Write necessary unit-test 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). - [ ] 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [RIP-70-1]Optimize the back pressure mechanism of the client [rocketmq]
RongtongJin merged PR #8661: URL: https://github.com/apache/rocketmq/pull/8661 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [RIP-70] Optimizing Lock Mechanisms [rocketmq]
RongtongJin closed issue #8442: [RIP-70] Optimizing Lock Mechanisms URL: https://github.com/apache/rocketmq/issues/8442 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq) branch develop updated (d3e5f70979 -> a28c2cbc7d)
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git from d3e5f70979 [ISSUE #8613] fix start failed when acl2.0 authentication enabled (#8614) add a28c2cbc7d [RIP-70-1] Optimize the back pressure mechanism of the client (#8661) No new revisions were added by this update. Summary of changes: .../impl/producer/DefaultMQProducerImpl.java | 71 +- .../rocketmq/client/lock/ReadWriteCASLock.java | 63 +++ .../client/producer/DefaultMQProducer.java | 61 ++- .../client/producer/DefaultMQProducerTest.java | 44 ++ 4 files changed, 222 insertions(+), 17 deletions(-) create mode 100644 client/src/main/java/org/apache/rocketmq/client/lock/ReadWriteCASLock.java
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: 1be91d68d1de2f75be149e69ac7e3e862dedfdb7 / tsaitsung-han.tht Update code format Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10915187484 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PUSH-CI" failed!
The GitHub Actions job "PUSH-CI" on rocketmq.git has failed. Run started by GitHub user RongtongJin (triggered by RongtongJin). Head commit for run: a28c2cbc7d7e112830e5e0bf65a87a1ff50be570 / hqbfz <125714719+3424672...@users.noreply.github.com> [RIP-70-1] Optimize the back pressure mechanism of the client (#8661) * Fix semaphore exception that failed halfway in the case of asynchronous message sending back pressure * Fix semaphore exception that failed halfway in the case of asynchronous message sending back pressure * Fix semaphore exception that failed halfway in the case of asynchronous message sending back pressure * Fixed variable typo * Fix semaphore exception that failed halfway in the case of asynchrono * Fix modifying the semaphore size at run time results in inaccurate semaphore calculations * optimize lock and introduce new lock * optimize code typo * Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values * fix fail test * adjust code typo * increase test * increase test * fix test * fix test Report URL: https://github.com/apache/rocketmq/actions/runs/10915194617 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" is working again!
The GitHub Actions job "Build" on rocketmq-clients.git has succeeded. Run started by GitHub user tsunghanjacktsai (triggered by tsunghanjacktsai). Head commit for run: e593bdc617643480c1cd7f90a0fc932c2c72ad31 / tsaitsung-han.tht Update code format Report URL: https://github.com/apache/rocketmq-clients/actions/runs/10915211776 With regards, GitHub Actions via GitBox
(rocketmq) branch develop updated: [ISSUE #8693] Fix checking MultiDispatchMessage when appending commitlog
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 280804c559 [ISSUE #8693] Fix checking MultiDispatchMessage when
appending commitlog
280804c559 is described below
commit 280804c5592341f92a43b6d72ec6e94db77b74ac
Author: Liu Shengzhong
AuthorDate: Wed Sep 18 13:57:20 2024 +0800
[ISSUE #8693] Fix checking MultiDispatchMessage when appending commitlog
---
store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 8 +---
.../main/java/org/apache/rocketmq/store/MessageExtEncoder.java| 2 +-
2 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index f34c6944c9..972e71aadd 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -61,6 +61,7 @@ import org.apache.rocketmq.store.config.MessageStoreConfig;
import org.apache.rocketmq.store.ha.HAService;
import org.apache.rocketmq.store.ha.autoswitch.AutoSwitchHAService;
import org.apache.rocketmq.store.logfile.MappedFile;
+import org.apache.rocketmq.store.queue.MultiDispatchUtils;
import org.apache.rocketmq.store.util.LibC;
import org.rocksdb.RocksDBException;
@@ -1903,7 +1904,7 @@ public class CommitLog implements Swappable {
// STORETIMESTAMP + STOREHOSTADDRESS + OFFSET
ByteBuffer preEncodeBuffer = msgInner.getEncodedBuff();
-boolean isMultiDispatchMsg =
messageStoreConfig.isEnableMultiDispatch() &&
CommitLog.isMultiDispatchMsg(msgInner);
+final boolean isMultiDispatchMsg =
CommitLog.isMultiDispatchMsg(messageStoreConfig, msgInner);
if (isMultiDispatchMsg) {
AppendMessageResult appendMessageResult =
handlePropertiesForLmqMsg(preEncodeBuffer, msgInner);
if (appendMessageResult != null) {
@@ -2244,8 +2245,9 @@ public class CommitLog implements Swappable {
return flushManager;
}
-public static boolean isMultiDispatchMsg(MessageExtBrokerInner msg) {
-return
StringUtils.isNoneBlank(msg.getProperty(MessageConst.PROPERTY_INNER_MULTI_DISPATCH))
&& !msg.getTopic().startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX);
+public static boolean isMultiDispatchMsg(MessageStoreConfig
messageStoreConfig, MessageExtBrokerInner msg) {
+return
StringUtils.isNotBlank(msg.getProperty(MessageConst.PROPERTY_INNER_MULTI_DISPATCH))
&&
+MultiDispatchUtils.isNeedHandleMultiDispatch(messageStoreConfig,
msg.getTopic());
}
private boolean isCloseReadAhead() {
diff --git
a/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
b/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
index 20e9a652b7..5c74918d9e 100644
--- a/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
+++ b/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
@@ -175,7 +175,7 @@ public class MessageExtEncoder {
public PutMessageResult encode(MessageExtBrokerInner msgInner) {
this.byteBuf.clear();
-if (messageStoreConfig.isEnableMultiDispatch() &&
CommitLog.isMultiDispatchMsg(msgInner)) {
+if (CommitLog.isMultiDispatchMsg(messageStoreConfig, msgInner)) {
return encodeWithoutProperties(msgInner);
}
Re: [I] [Enhancement] LMQ logic queue order maybe wrong [rocketmq]
RongtongJin closed issue #8693: [Enhancement] LMQ logic queue order maybe wrong URL: https://github.com/apache/rocketmq/issues/8693 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [ISSUE #8693] Fix checking MultiDispatchMessage when appending commitlog [rocketmq]
RongtongJin merged PR #8700: URL: https://github.com/apache/rocketmq/pull/8700 -- 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "PUSH-CI" failed!
The GitHub Actions job "PUSH-CI" on rocketmq.git has failed. Run started by GitHub user RongtongJin (triggered by RongtongJin). Head commit for run: 280804c5592341f92a43b6d72ec6e94db77b74ac / Liu Shengzhong [ISSUE #8693] Fix checking MultiDispatchMessage when appending commitlog Report URL: https://github.com/apache/rocketmq/actions/runs/10916402536 With regards, GitHub Actions via GitBox
