Re: [I] [Bug] plain_acl.yml garbled characters when creating acl account with empty topicPerms/groupPerms array [rocketmq]
humkum commented on issue #8229: URL: https://github.com/apache/rocketmq/issues/8229#issuecomment-2141347280 You can open a mr to fix this bug. -- 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 "Coverage" is working again!
The GitHub Actions job "Coverage" on rocketmq.git has succeeded. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 41ade609a953be234f285eb01626979c0d2295cd / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313866761 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9313915244 With regards, GitHub Actions via GitBox
(rocketmq-clients) tag golang/v5.1.1-rc1 created (now d1a7701d)
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a change to tag golang/v5.1.1-rc1 in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git at d1a7701d (commit) No new revisions were added by this update.
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9313890810 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: bb8c5130520dcae1a6bbec9267a92d6b36c64073 / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313610086 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: e958e7aab39760aa5e15ab98521e5c9c3f126bac / 黄梓淇 Merge branch 'addm2' into addm Signed-off-by: 黄梓淇 Report URL: https://github.com/apache/rocketmq/actions/runs/9313590946 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" is working again!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has succeeded. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 41ade609a953be234f285eb01626979c0d2295cd / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313866770 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" is working again!
The GitHub Actions job "PR-CI" on rocketmq.git has succeeded. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 41ade609a953be234f285eb01626979c0d2295cd / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313866765 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: e958e7aab39760aa5e15ab98521e5c9c3f126bac / 黄梓淇 Merge branch 'addm2' into addm Signed-off-by: 黄梓淇 Report URL: https://github.com/apache/rocketmq/actions/runs/9313590952 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: bb8c5130520dcae1a6bbec9267a92d6b36c64073 / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313610094 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: bb8c5130520dcae1a6bbec9267a92d6b36c64073 / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313610092 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9313617881 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: bb8c5130520dcae1a6bbec9267a92d6b36c64073 / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 Report URL: https://github.com/apache/rocketmq/actions/runs/9313610084 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9313600235 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: e958e7aab39760aa5e15ab98521e5c9c3f126bac / 黄梓淇 Merge branch 'addm2' into addm Signed-off-by: 黄梓淇 Report URL: https://github.com/apache/rocketmq/actions/runs/9313590948 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has succeeded. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9312345268 With regards, GitHub Actions via GitBox
Re: [I] Multiple instances in the same application share MQClientInstance [rocketmq]
caimofei commented on issue #2730: URL: https://github.com/apache/rocketmq/issues/2730#issuecomment-2141184908 > @zcsh0721 我和其他同学交流了一下，这个变更的目的是应对容器化部署环境下pid冲突的情况。想复用MQClientInstance可以手动设置instanceName。 有点疑问 1. 您描述这个问题就是造成MQClientInstance对象 clientId重复.并且是在不同的JVM进程中。不同JVM进程中有相同的clientId的MQClientInstance对象有什么问题？还是说在服务端需要要求这个clientId不重复？ 2. 如果说服务端需要要求clinetId不重复。那么如果想复用MQClientInstance对象，手动设置instanceName的情况下，不是同样造成clientId的重复吗？好像又回到了问题的源头 -- 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] Update 10consumerretrypolicy.md [rocketmq-site]
boostarea opened a new pull request, #657: URL: https://github.com/apache/rocketmq-site/pull/657 fix(10consumerretrypolicy.md).syntax errors Please do not create a Pull Request without creating an issue first. ## What is the purpose of the change In the CN documentation, there is a clerical error in "Consumption Retry" section:"超过一次定数后若还未消费成功". ## Brief changelog modify ""超过一次定数后若还未消费成功" to "超过一定次数后若还未消费成功". ## 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
[GH] (rocketmq): Workflow run "PUSH-CI" failed!
The GitHub Actions job "PUSH-CI" on rocketmq.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9312345261 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9312345269 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" is working again!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has succeeded. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 7a5ea90cb79cc28ae86c368f22d1ab7d2f6f24cc / wuyue [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) Report URL: https://github.com/apache/rocketmq/actions/runs/9312345262 With regards, GitHub Actions via GitBox
(rocketmq) branch develop updated (db163b431e -> 7a5ea90cb7)
This is an automated email from the ASF dual-hosted git repository. lizhimin pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git from db163b431e Revert "[ISSUE #7757] Use `CompositeByteBuf` to prevent memory copy. (#7694)" (#8209) add 7a5ea90cb7 [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY (#8054) No new revisions were added by this update. Summary of changes: .../java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java | 2 +- .../org/apache/rocketmq/broker/processor/SendMessageProcessorTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-)
Re: [I] [Bug] Producer should be retry put message if OS_PAGE_CACHE_BUSY [rocketmq]
lizhimins closed issue #8053: [Bug] Producer should be retry put message if OS_PAGE_CACHE_BUSY URL: https://github.com/apache/rocketmq/issues/8053 -- 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 #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY [rocketmq]
lizhimins merged PR #8054: URL: https://github.com/apache/rocketmq/pull/8054 -- 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] use helm-charts for quickly deploying a cluster to facilitate message transmission and reception. [rocketmq-site]
RongtongJin commented on code in PR #655: URL: https://github.com/apache/rocketmq-site/pull/655#discussion_r1621586798 ## docs/01-introduction/02quickstartWithHelmInKubernetes.md: ## @@ -0,0 +1,143 @@ +### QuickStart + + 前提条件 + +- 一个运行中的 `Kubernetes` 集群 +- 已安装并配置好的 `kubectl` +- 已安装的 `Helm` + + 第一步：安装 Helm + +确保你的系统上已经安装了 Helm： + +```bash +$ helm version +``` + +如果未安装 Helm，可以使用以下命令进行安装： + +```bash +$ curl https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 | bash +``` + + 第二步：添加 RocketMQ Helm 仓库 + +添加 RocketMQ 的 Helm chart 仓库： + +```bash +$ helm repo add rocketmq-repo https://helm-charts.itboon.top/rocketmq Review Comment: 建议采用官方的chart https://github.com/apache/rocketmq-docker -- 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-site) branch new-official-website updated: Updated descriptions in quickstart for version 5.x (#656)
This is an automated email from the ASF dual-hosted git repository. jinrongtong 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 c38cb00c70 Updated descriptions in quickstart for version 5.x (#656) c38cb00c70 is described below commit c38cb00c706a2e42f582c71a8b48b1f5ec82b0f0 Author: CindyXC <72009468+cindy0...@users.noreply.github.com> AuthorDate: Fri May 31 10:03:19 2024 +0800 Updated descriptions in quickstart for version 5.x (#656) Co-authored-by: XCii1 <13015886...@139.com> --- versioned_docs/version-5.0/02-quickStart/01quickstart.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/versioned_docs/version-5.0/02-quickStart/01quickstart.md b/versioned_docs/version-5.0/02-quickStart/01quickstart.md index 57a949a62a..d182206373 100644 --- a/versioned_docs/version-5.0/02-quickStart/01quickstart.md +++ b/versioned_docs/version-5.0/02-quickStart/01quickstart.md @@ -50,7 +50,7 @@ The Name Server boot success... ## 3. 启动Broker+Proxy -NameServer成功启动后，我们启动Broker和Proxy，5.x 版本下我们建议使用 Local 模式部署，即 Broker 和 Proxy 同进程部署。5.x 版本也支持 Broker 和 Proxy 分离部署以实现更灵活的集群能力。详情参考[部署教程](../05-deploymentOperations/01deploy.md)。 +NameServer成功启动后，我们启动Broker和Proxy。这里我们使用 Local 模式部署，即 Broker 和 Proxy 同进程部署。5.x 版本也支持 Broker 和 Proxy 分离部署以实现更灵活的集群能力。详情参考[部署教程](../05-deploymentOperations/01deploy.md)。 ```shell ### 先启动broker
Re: [PR] Updated descriptions in quickstart for version 5.x [rocketmq-site]
RongtongJin merged PR #656: URL: https://github.com/apache/rocketmq-site/pull/656 -- 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
[I] [Bug] plain_acl.yml garbled characters when creating acl account with empty topicPerms/topicPerms array [rocketmq]
hujie6 opened a new issue, #8229:
URL: https://github.com/apache/rocketmq/issues/8229
### 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
### RocketMQ version
rocketmq5.2.0
### JDK Version
jdk1.8
### Describe the Bug
DefaultMQAdminExt defaultMQAdminExt = new DefaultMQAdminExt(new
AclClientRPCHook(new SessionCredentials("rocketmq2", "12345678")));
defaultMQAdminExt.setNamesrvAddr("127.0.0.1:9876");
defaultMQAdminExt.start();
PlainAccessConfig accessConfig = new PlainAccessConfig();
accessConfig.setAccessKey("test-");
accessConfig.setSecretKey("sswewewewew");
accessConfig.setAdmin(false);
accessConfig.setGroupPerms(new ArrayList<>());
accessConfig.setTopicPerms(new ArrayList<>());
defaultMQAdminExt.createAndUpdatePlainAccessConfig("127.0.0.1:10911",
accessConfig);
when groupPerms and topicPerms are empty array,
createAndUpdatePlainAccessConfig method will cause plain_acl.yml garbled
characters. like this:
- accessKey: test-
admin: false
defaultGroupPerm: null
defaultTopicPerm: null
groupPerms: &id003 []
secretKey: sswewewewew
topicPerms: *id003
whiteRemoteAddress: null
### Steps to Reproduce
topicPerms or groupPerms are empty array when creating acl
### What Did You Expect to See?
if topicPerms or groupPerms are empty, donot cause garbled characters.
### What Did You See Instead?
- accessKey: test-
admin: false
defaultGroupPerm: null
defaultTopicPerm: null
groupPerms: []
secretKey: sswewewewew
topicPerms: []
whiteRemoteAddress: null
### Additional Context
How to fix：
org.apache.rocketmq.common.Util.split method should not return
Collections.EMPTY_LIST, return new ArrayList<>() instead
--
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): 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: db163b431ea9366d1121d04ded4b660fd8a31624 / yuz10 <845238...@qq.com> Revert "[ISSUE #7757] Use `CompositeByteBuf` to prevent memory copy. (#7694)" (#8209) This reverts commit 7a36d4d736ae8d6d92658e3bdb18f1cd5c0afdb0. Report URL: https://github.com/apache/rocketmq/actions/runs/9310945231 With regards, GitHub Actions via GitBox
Re: [I] [Bug] rocketmq::Producer对象析构crash [rocketmq-clients]
github-actions[bot] closed issue #738: [Bug] rocketmq::Producer对象析构crash URL: https://github.com/apache/rocketmq-clients/issues/738 -- 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] rocketmq::Producer对象析构crash [rocketmq-clients]
github-actions[bot] commented on issue #738: URL: https://github.com/apache/rocketmq-clients/issues/738#issuecomment-2141035801 This issue 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] The same message is consumed by multiple consumers under the same consumption group [rocketmq]
github-actions[bot] commented on issue #6840: URL: https://github.com/apache/rocketmq/issues/6840#issuecomment-2141027113 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
Re: [PR] [ISSUE #8220] Add a message sending time cost prompt for message sending timeout [rocketmq]
humkum commented on PR #8221: URL: https://github.com/apache/rocketmq/pull/8221#issuecomment-2139386827 This is really important for troubleshooting problems！ -- 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] [Feature] Add two metrics rocketmq_active_topic_number and rocketmq_active_subscription_number [rocketmq]
humkum commented on issue #8223: URL: https://github.com/apache/rocketmq/issues/8223#issuecomment-2139380886 Here you can only get the total number of topics and subscription groups, but cannot determine whether these topics and subscription groups are active. Would it be more accurate to call it rocketmq_total_topic_number & rocketmq_total_subscription_number? -- 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 "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user yx9o (triggered by yx9o). Head commit for run: edddf758ecc9ed24aed604508b5ec20c61971ac4 / yx9o [ISSUE #8227] Repeated merging in the constructor Report URL: https://github.com/apache/rocketmq/actions/runs/9301199852 With regards, GitHub Actions via GitBox
[PR] Updated descriptions in quickstart for version 5.x [rocketmq-site]
Cindy0802 opened a new pull request, #656: URL: https://github.com/apache/rocketmq-site/pull/656 Updated descriptions in quickstart for version 5.x -- 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 #8227] Repeated merging in the constructor [rocketmq]
codecov-commenter commented on PR #8228: URL: https://github.com/apache/rocketmq/pull/8228#issuecomment-2139317596 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8228?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report All modified and coverable lines are covered by tests :white_check_mark: > Project coverage is 42.89%. Comparing base [(`db163b4`)](https://app.codecov.io/gh/apache/rocketmq/commit/db163b431ea9366d1121d04ded4b660fd8a31624?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) to head [(`edddf75`)](https://app.codecov.io/gh/apache/rocketmq/commit/edddf758ecc9ed24aed604508b5ec20c61971ac4?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache). Additional details and impacted files ```diff @@ Coverage Diff @@ ## develop#8228 +/- ## = - Coverage 42.93% 42.89% -0.05% + Complexity 1038010371 -9 = Files 1270 1270 Lines 8872488716 -8 Branches 1140611406 = - Hits 3809638053 -43 - Misses 4592745955 +28 - Partials4701 4708 +7 ``` [:umbrella: View full report in Codecov by Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/8228?dropdown=coverage&src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache). :loudspeaker: Have feedback on the report? [Share it here](https://about.codecov.io/codecov-pr-comment-feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache). -- 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] Add Docker-Compose deployment method to QuickStart guide for Version 5.x [rocketmq-site]
RongtongJin commented on code in PR #647: URL: https://github.com/apache/rocketmq-site/pull/647#discussion_r1620490395 ## versioned_docs/version-5.0/02-quickStart/03quickstartWithDockercompose.md: ## @@ -0,0 +1,215 @@ +# Docker-compose 部署 RocketMQ + +这一节介绍如何使用Docker-compose快速部署一个单节点单副本 RocketMQ 服务，并完成简单的消息收发。 + +:::tip 系统要求 + +1. 64位操作系统 +2. 64位 JDK 1.8+ + +::: + + +## 1.编写docker-compose + +为了快速启动并运行 RockerMQ 集群，您可以使用以下模板通过修改或添加环境部分中的配置来创建 docker-compose.yml 文件。 +```text +version: '3.8' +services: + namesrv: +image: apache/rocketmq:5.2.0 +container_name: rmqnamesrv +ports: + - 9876:9876 +networks: + - rocketmq +command: sh mqnamesrv + broker: +image: apache/rocketmq:5.2.0 +container_name: rmqbroker +ports: + - 10909:10909 + - 10911:10911 + - 10912:10912 +environment: + - NAMESRV_ADDR=rmqnamesrv:9876 +depends_on: + - namesrv +networks: + - rocketmq +command: sh mqbroker + proxy: +image: apache/rocketmq:5.2.0 +container_name: rmqproxy +networks: + - rocketmq +depends_on: + - broker + - namesrv +ports: + - 8080:8080 + - 8081:8081 +restart: on-failure +environment: + - NAMESRV_ADDR=rmqnamesrv:9876 +command: sh mqproxy +networks: + rocketmq: +driver: bridge +``` + +## 2.启动RocketMQ集群 +根据 docker-compose.yml 文件启动所有定义的服务。 + +import Tabs from '@theme/Tabs'; +import TabItem from '@theme/TabItem'; + + + +```shell +docker-compose up -d +``` + + +```shell +docker-compose -p rockermq_project up -d +``` + + + +## 3.工具测试消息收发 +```shell +# 进入broker容器 +$ docker exec -it rmqbroker bash + +$ sh tools.sh org.apache.rocketmq.example.quickstart.Producer + SendResult [sendStatus=SEND_OK, msgId= ... + +$ sh tools.sh org.apache.rocketmq.example.quickstart.Consumer + ConsumeMessageThread_%d Receive New Messages: [MessageExt... +``` Review Comment: 这一节去掉吧，这里其实采用了4.x remoting的发送方式 -- 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] Add Docker deployment method to QuickStart guide for Version 5.x [rocketmq-site]
RongtongJin commented on code in PR #646: URL: https://github.com/apache/rocketmq-site/pull/646#discussion_r1620487704 ## versioned_docs/version-5.0/02-quickStart/02quickstartWithDocker5.x.md: ## @@ -0,0 +1,260 @@ +# Docker 部署 RocketMQ 5.X + +这一节介绍如何使用Docker快速部署一个单节点单副本 RocketMQ 服务，并完成简单的消息收发。 + +:::tip 系统要求 + +1. 64位操作系统 +2. 64位 JDK 1.8+ + +::: + +## 1.拉取RocketMQ镜像 +这里以[dockerhub](https://hub.docker.com/r/apache/rocketmq/tags)上 RocketMQ 5.2.0 版本的镜像为例，介绍部署过程。 + +```shell +docker pull apache/rocketmq:5.2.0 +``` + +## 2.创建容器共享网络 +RocketMQ中有多个服务，需要创建多个容器，创建 docker 网络便于容器间相互通信。 + +```shell +docker network create rocketmq +``` + +## 3.启动NameServer + +```shell +# 启动 NameServer +docker run -d --name rmqnamesrv -p 9876:9876 --network rocketmq apache/rocketmq:5.2.0 sh mqnamesrv + +# 验证 NameServer 是否启动成功 +docker logs -f rmqnamesrv +``` +:::info + +我们可以看到 **'The Name Server boot success..'，** 表示NameServer 已成功启动。 + +::: + +## 4.启动 Broker+Proxy +NameServer 成功启动后，我们启动 Broker 和 Proxy ，5.x 版本下我们建议使用 Local 模式部署，即 Broker 和 Proxy 同进程部署。 + +import Tabs from '@theme/Tabs'; +import TabItem from '@theme/TabItem'; + + + + +```code +# 配置 Broker 的IP地址 +echo "brokerIP1=127.0.0.1" > broker.conf + +# 启动 Broker 和 Proxy +docker run -d \ +--name rmqbroker \ +--network rocketmq \ +-p 10912:10912 -p 10911:10911 -p 10909:10909 \ +-p 8080:8080 -p 8081:8081 \ +-e "NAMESRV_ADDR=rmqnamesrv:9876" \ +-v ./broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf \ +apache/rocketmq:5.2.0 sh mqbroker --enable-proxy \ +-c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf + +# 验证 Broker 是否启动成功 +docker exec -it rmqbroker bash -c "tail -n 10 /home/rocketmq/logs/rocketmqlogs/proxy.log" +``` + + + +```code +# 配置 Broker 的 IP 地址 +echo "brokerIP1=127.0.0.1" > broker.conf + +# 启动 Broker 和 Proxy +docker run -d ^ +--name rmqbroker ^ +--net rocketmq ^ +-p 10912:10912 -p 10911:10911 -p 10909:10909 ^ +-p 8080:8080 -p 8081:8081 \ +-e "NAMESRV_ADDR=rmqnamesrv:9876" ^ +-v %cd%\broker.conf:/home/rocketmq/rocketmq-5.2.0/conf/broker.conf ^ +apache/rocketmq:5.2.0 sh mqbroker --enable-proxy \ +-c /home/rocketmq/rocketmq-5.2.0/conf/broker.conf + +# 验证 Broker 是否启动成功 +docker exec -it rmqbroker bash -c "tail -n 10 /home/rocketmq/logs/rocketmqlogs/proxy.log" +``` + + + + + + +:::info + +我们可以看到 **'The broker boot success..'，** 表示 Broker 已成功启动。 + +::: + +:::note + +至此，一个单节点副本的 RocketMQ 集群已经部署起来了，我们可以利用脚本进行简单的消息收发。 + +::: + +## 5.工具测试消息收发 +```shell +# 进入broker容器 +$ docker exec -it rmqbroker bash + +$ sh tools.sh org.apache.rocketmq.example.quickstart.Producer + SendResult [sendStatus=SEND_OK, msgId= ... + +$ sh tools.sh org.apache.rocketmq.example.quickstart.Consumer + ConsumeMessageThread_%d Receive New Messages: [MessageExt... +``` Review Comment: 第5节去掉吧。这里其实采用的是4.x remoting的发送 -- 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 "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: 2f3cd2be2a597ad1f77410f92762ff9b2d2bb595 / 黄梓淇 Merge remote-tracking branch 'origin/addm2' into addm2 # Conflicts: # broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java # broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java Report URL: https://github.com/apache/rocketmq/actions/runs/9300744660 With regards, GitHub Actions via GitBox
Re: [PR] Add Docker deployment method to QuickStart guide for Version 5.x [rocketmq-site]
RongtongJin commented on code in PR #646: URL: https://github.com/apache/rocketmq-site/pull/646#discussion_r1620482246 ## versioned_docs/version-5.0/02-quickStart/02quickstartWithDocker5.x.md: ## @@ -0,0 +1,260 @@ +# Docker 部署 RocketMQ 5.X + +这一节介绍如何使用Docker快速部署一个单节点单副本 RocketMQ 服务，并完成简单的消息收发。 + +:::tip 系统要求 + +1. 64位操作系统 +2. 64位 JDK 1.8+ + +::: + +## 1.拉取RocketMQ镜像 +这里以[dockerhub](https://hub.docker.com/r/apache/rocketmq/tags)上 RocketMQ 5.2.0 版本的镜像为例，介绍部署过程。 + +```shell +docker pull apache/rocketmq:5.2.0 +``` + +## 2.创建容器共享网络 +RocketMQ中有多个服务，需要创建多个容器，创建 docker 网络便于容器间相互通信。 + +```shell +docker network create rocketmq +``` + +## 3.启动NameServer + +```shell +# 启动 NameServer +docker run -d --name rmqnamesrv -p 9876:9876 --network rocketmq apache/rocketmq:5.2.0 sh mqnamesrv + +# 验证 NameServer 是否启动成功 +docker logs -f rmqnamesrv +``` +:::info + +我们可以看到 **'The Name Server boot success..'，** 表示NameServer 已成功启动。 + +::: + +## 4.启动 Broker+Proxy +NameServer 成功启动后，我们启动 Broker 和 Proxy ，5.x 版本下我们建议使用 Local 模式部署，即 Broker 和 Proxy 同进程部署。 Review Comment: 不要建议使用Local模式部署，只是quick start可以使用local部署进行验证。 ## versioned_docs/version-5.0/02-quickStart/02quickstartWithDocker5.x.md: ## @@ -0,0 +1,260 @@ +# Docker 部署 RocketMQ 5.X Review Comment: “Docker 部署 RocketMQ”即可 -- 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] Add English version for Docker-Compose Deployment 4.x [rocketmq-site]
RongtongJin merged PR #653: URL: https://github.com/apache/rocketmq-site/pull/653 -- 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 "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user yx9o (triggered by yx9o). Head commit for run: db163b431ea9366d1121d04ded4b660fd8a31624 / yuz10 <845238...@qq.com> Revert "[ISSUE #7757] Use `CompositeByteBuf` to prevent memory copy. (#7694)" (#8209) This reverts commit 7a36d4d736ae8d6d92658e3bdb18f1cd5c0afdb0. Report URL: https://github.com/apache/rocketmq/actions/runs/9301226362 With regards, GitHub Actions via GitBox
(rocketmq-site) branch new-official-website updated: Add English version for Docker-Compose Deployment 4.x (#653)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 5baef991ac Add English version for Docker-Compose Deployment 4.x (#653)
5baef991ac is described below
commit 5baef991ac7a86853e7e9d70fa10cffa7767c395
Author: CindyXC <72009468+cindy0...@users.noreply.github.com>
AuthorDate: Thu May 30 18:56:47 2024 +0800
Add English version for Docker-Compose Deployment 4.x (#653)
* Add Docker-Compose deployment method to QuickStart guide for Version 4.x
* Modified some descriptions.
* Reorder files
* Update file name numbering.
* Fix bug in docker-compose start command on Windows
* Add English version for Docker-Compose Deployment 4.x
-
Co-authored-by: XCii1 <13015886...@139.com>
---
.../02quickstartWithDockercompose.md | 179 +
1 file changed, 179 insertions(+)
diff --git
a/i18n/en/docusaurus-plugin-content-docs/current/01-introduction/02quickstartWithDockercompose.md
b/i18n/en/docusaurus-plugin-content-docs/current/01-introduction/02quickstartWithDockercompose.md
new file mode 100644
index 00..96a1cde872
--- /dev/null
+++
b/i18n/en/docusaurus-plugin-content-docs/current/01-introduction/02quickstartWithDockercompose.md
@@ -0,0 +1,179 @@
+# Docker-compose Deployment of RocketMQ
+
+This section introduces how to quickly deploy a single-node, single-replica
RocketMQ service using Docker-compose and complete simple message sending and
receiving.
+
+:::tip SYSTEM REQUIREMENTS
+
+1. 64-bit operating system
+2. 64-bit JDK 1.8+
+
+:::
+## 1.Configure broker.conf
+```shell
+# Configure the broker's IP address
+echo "brokerIP1=127.0.0.1" > broker.conf
+```
+
+## 2.Configure docker-compose
+To quickly start and run the RockerMQ cluster, you can use the following
template to create a docker-compose.yml file by modifying or adding
configurations in the environment section.
+```text
+version: '3.8'
+
+services:
+ namesrv:
+image: apache/rocketmq:4.9.6
+container_name: rmqnamesrv
+ports:
+ - 9876:9876
+networks:
+ - rocketmq
+command: sh mqnamesrv
+
+ broker:
+image: apache/rocketmq:4.9.6
+container_name: rmqbroker
+ports:
+ - 10909:10909
+ - 10911:10911
+ - 10912:10912
+environment:
+ - NAMESRV_ADDR=rmqnamesrv:9876
+volumes:
+ - ./broker.conf:/home/rocketmq/rocketmq-4.9.6/conf/broker.conf
+depends_on:
+ - namesrv
+networks:
+ - rocketmq
+command: sh mqbroker -c /home/rocketmq/rocketmq-4.9.6/conf/broker.conf
+
+networks:
+ rocketmq:
+driver: bridge
+```
+
+## 3.Start RocketMQ
+Start all defined services according to the docker-compose.yml file.
+
+import Tabs from '@theme/Tabs';
+import TabItem from '@theme/TabItem';
+
+
+
+
+```code
+docker-compose up -d
+```
+
+
+
+
+```code
+docker-compose -p rocketmq_project up -d
+```
+
+
+
+## 4.Send and Receive Messages with Tools
+```shell
+# Enter the broker container
+$ docker exec -it rmqbroker bash
+
+$ sh tools.sh org.apache.rocketmq.example.quickstart.Producer
+ SendResult [sendStatus=SEND_OK, msgId= ...
+
+$ sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
+ ConsumeMessageThread_%d Receive New Messages: [MessageExt...
+```
+
+## 5.Send and Receive Messages with SDK
+
+We can also try to use the client sdk to send and receive messages.
+
+1. Create a java project.
+
+2. Add sdk dependency to pom.xml
+
+ ```
+
+ org.apache.rocketmq
+ rocketmq-client
+ 4.9.6
+
+ ```
+
+3. In the created Java project, create and run a program to send a simple
message. Apache RocketMQ can send messages in three ways: **synchronous,
asynchronous, and one-way transmission**. Here we use the synchronous mode as
an example:
+
+ ```java
+ import org.apache.rocketmq.client.producer.DefaultMQProducer;
+ import org.apache.rocketmq.client.producer.SendResult;
+ import org.apache.rocketmq.common.message.Message;
+
+ public class ProducerExample {
+ public static void main(String[] args) throws Exception {
+ // Create producer instance and set the producer group name
+ DefaultMQProducer producer = new
DefaultMQProducer("please_rename_unique_group_name");
+ // Set the Name Server address (replace with actual Name Server
address)
+ producer.setNamesrvAddr("localhost:9876");
+ producer.start();
+
+ try {
+ // Create a message instance, specifying the topic, tag, and
message body
+ Message msg = new Message("TestTopic", "TagA", ("Hello
RocketMQ").getBytes());
+ // Send the message and get the send result
+ SendResult sendResult = producer.send(msg);
+ Syst
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user yx9o (triggered by yx9o). Head commit for run: edddf758ecc9ed24aed604508b5ec20c61971ac4 / yx9o [ISSUE #8227] Repeated merging in the constructor Report URL: https://github.com/apache/rocketmq/actions/runs/9301199864 With regards, GitHub Actions via GitBox
[PR] [ISSUE #8227] Repeated merging in the constructor [rocketmq]
yx9o opened a new pull request, #8228: URL: https://github.com/apache/rocketmq/pull/8228 Fix #8227 . -- 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-site): Workflow run "Pre Build CI" is working again!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has succeeded. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: 0e3b66c2b09ec887c1ada73ca304bbd62c903ed4 / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> Fixed the bugs Report URL: https://github.com/apache/rocketmq-site/actions/runs/9301134493 With regards, GitHub Actions via GitBox
[I] [Enhancement] Optimize DefaultMQPushConsumer construction method [rocketmq]
yx9o opened a new issue, #8227: URL: https://github.com/apache/rocketmq/issues/8227 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary I found a duplicate structure in the constructor. https://github.com/apache/rocketmq/assets/12792261/c55635f4-d610-4cdf-890e-a0f20b936091";> ### Motivation To reduce code duplication and improve code reusability. ### Describe the Solution You'd Like We can let one constructor call another constructor, and finally perform the actual assignment operation only in one constructor. ### Describe Alternatives You've Considered In each constructor, directly call the most complete constructor. ### Additional Context _No response_ -- 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-site): Workflow run "Pre Build CI" failed!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has failed. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: 002c60ca1dacdd043f0e849d4d91a879f0d9b683 / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> Revised some sentences. Report URL: https://github.com/apache/rocketmq-site/actions/runs/9301052054 With regards, GitHub Actions via GitBox
[GH] (rocketmq-site): Workflow run "Pre Build CI" failed!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has failed. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: 5b9a665e5f662dbed38d00f07ce8be5c8c09b289 / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> Add English version Report URL: https://github.com/apache/rocketmq-site/actions/runs/9301017837 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user Stephanie0002 (triggered by Stephanie0002). Head commit for run: db163b431ea9366d1121d04ded4b660fd8a31624 / yuz10 <845238...@qq.com> Revert "[ISSUE #7757] Use `CompositeByteBuf` to prevent memory copy. (#7694)" (#8209) This reverts commit 7a36d4d736ae8d6d92658e3bdb18f1cd5c0afdb0. Report URL: https://github.com/apache/rocketmq/actions/runs/9300779078 With regards, GitHub Actions via GitBox
[PR] duse helm-charts for quickly deploying a cluster to facilitate message transmission and reception. [rocketmq-site]
Baiyelovecode opened a new pull request, #655: URL: https://github.com/apache/rocketmq-site/pull/655 Please do not create a Pull Request without creating an issue first. ## What is the purpose of the change helm-charts for quickly deploying a cluster to facilitate message transmission and reception. ## Brief changelog I added a Quickstart guide for RocketMQ with container-related setup, using Kubernetes (k8s) and helm-charts for quickly deploying a cluster to facilitate message transmission and reception. ## Verifying this change l have used some computer to test it Follow this checklist to help us incorporate your contribution quickly and easily: - -- 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
[I] use I noticed that there are currently no container-related Quickstart setup documents, so I added a Quickstart guide for RocketMQ with container-related setup, using Kubernetes (k8s) and helm-cha
Baiyelovecode opened a new issue, #654: URL: https://github.com/apache/rocketmq-site/issues/654 I noticed that there are currently no container-related Quickstart setup documents, so I added a Quickstart guide for RocketMQ with container-related setup, using Kubernetes (k8s) and helm-charts for quickly deploying a cluster to facilitate message transmission and reception. -- 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-site): Workflow run "Pre Build CI" is working again!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has succeeded. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: 7dcfda835b35bde834fe4af5cc5c16307e948517 / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> fixed bugs Report URL: https://github.com/apache/rocketmq-site/actions/runs/9300028269 With regards, GitHub Actions via GitBox
[GH] (rocketmq-site): Workflow run "Pre Build CI" failed!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has failed. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: fdcface24453b2950d709f5d8df6bff296331fbd / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> Delete the configuration file and use the default settings. Report URL: https://github.com/apache/rocketmq-site/actions/runs/9299868288 With regards, GitHub Actions via GitBox
[GH] (rocketmq-site): Workflow run "Pre Build CI" failed!
The GitHub Actions job "Pre Build CI" on rocketmq-site.git has failed. Run started by GitHub user kaxiya1021 (triggered by kaxiya1021). Head commit for run: 17fd429fa2a8e44c292b24d7c2f8d1675a2ee543 / Kaxiya <125204531+kaxiya1...@users.noreply.github.com> Modified Docker Compose deployment for RocketMQ version 5.0 Report URL: https://github.com/apache/rocketmq-site/actions/runs/9299594357 With regards, GitHub Actions via GitBox
[PR] Add English version for Docker-Compose Deployment 4.x [rocketmq-site]
Cindy0802 opened a new pull request, #653: URL: https://github.com/apache/rocketmq-site/pull/653 Add English version for Docker-Compose Deployment 4.x -- 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] multithread share Producer failed accidentally , error “ProducerSendSyncFailed: No route info of this topic” [rocketmq-client-cpp]
ItisDL commented on issue #352: URL: https://github.com/apache/rocketmq-client-cpp/issues/352#issuecomment-2138997136 我也遇到了一样的问题,有解吗 -- 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-site) branch new-official-website updated: Add Docker-Compose deployment method to QuickStart guide for Version 4.x (#644)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 28fa38e252 Add Docker-Compose deployment method to QuickStart guide
for Version 4.x (#644)
28fa38e252 is described below
commit 28fa38e25209a4f48844b494075b6ff3beb45042
Author: CindyXC <72009468+cindy0...@users.noreply.github.com>
AuthorDate: Thu May 30 16:02:47 2024 +0800
Add Docker-Compose deployment method to QuickStart guide for Version 4.x
(#644)
* Add Docker-Compose deployment method to QuickStart guide for Version 4.x
* Modified some descriptions.
* Reorder files
* Update file name numbering.
* Fix bug in docker-compose start command on Windows
-
Co-authored-by: XCii1 <13015886...@139.com>
---
.../02quickstartWithDockercompose.md | 179 +
1 file changed, 179 insertions(+)
diff --git a/docs/01-introduction/02quickstartWithDockercompose.md
b/docs/01-introduction/02quickstartWithDockercompose.md
new file mode 100644
index 00..13b0c1d43e
--- /dev/null
+++ b/docs/01-introduction/02quickstartWithDockercompose.md
@@ -0,0 +1,179 @@
+# Docker-compose 部署 RocketMQ
+
+这一节介绍如何使用Docker-compose快速部署一个单节点单副本 RocketMQ 服务，并完成简单的消息收发。
+
+:::tip 系统要求
+
+1. 64位操作系统
+2. 64位 JDK 1.8+
+
+:::
+## 1.配置 broker.conf
+```shell
+# 配置 broker 的IP地址
+echo "brokerIP1=127.0.0.1" > broker.conf
+```
+
+## 2.编写docker-compose
+为了快速启动并运行 RockerMQ 集群，您可以使用以下模板通过修改或添加环境部分中的配置来创建 docker-compose.yml 文件。
+```text
+version: '3.8'
+
+services:
+ namesrv:
+image: apache/rocketmq:4.9.6
+container_name: rmqnamesrv
+ports:
+ - 9876:9876
+networks:
+ - rocketmq
+command: sh mqnamesrv
+
+ broker:
+image: apache/rocketmq:4.9.6
+container_name: rmqbroker
+ports:
+ - 10909:10909
+ - 10911:10911
+ - 10912:10912
+environment:
+ - NAMESRV_ADDR=rmqnamesrv:9876
+volumes:
+ - ./broker.conf:/home/rocketmq/rocketmq-4.9.6/conf/broker.conf
+depends_on:
+ - namesrv
+networks:
+ - rocketmq
+command: sh mqbroker -c /home/rocketmq/rocketmq-4.9.6/conf/broker.conf
+
+networks:
+ rocketmq:
+driver: bridge
+```
+
+## 3.启动RocketMQ集群
+根据 docker-compose.yml 文件启动所有定义的服务。
+
+import Tabs from '@theme/Tabs';
+import TabItem from '@theme/TabItem';
+
+
+
+
+```code
+docker-compose up -d
+```
+
+
+
+
+```code
+docker-compose -p rocketmq_project up -d
+```
+
+
+
+## 4.工具测试消息收发
+```shell
+# 进入broker容器
+$ docker exec -it rmqbroker bash
+
+$ sh tools.sh org.apache.rocketmq.example.quickstart.Producer
+ SendResult [sendStatus=SEND_OK, msgId= ...
+
+$ sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
+ ConsumeMessageThread_%d Receive New Messages: [MessageExt...
+```
+
+## 5.SDK测试消息收发
+
+工具测试完成后，我们可以尝试使用 SDK 收发消息，这里以 Java SDK 为例介绍一下消息收发过程。
+
+1. 在IDEA中创建一个Java工程。
+
+2. 在 *pom.xml* 文件中添加以下依赖引入Java依赖库
+
+ ```
+
+ org.apache.rocketmq
+ rocketmq-client
+ 4.9.6
+
+ ```
+
+3. 在已创建的Java工程中，创建发送普通消息程序并运行，Apache
RocketMQ可用于以三种方式发送消息：**同步、异步和单向传输**，这里以同步模式为示例：
+
+ ```java
+ import org.apache.rocketmq.client.producer.DefaultMQProducer;
+ import org.apache.rocketmq.client.producer.SendResult;
+ import org.apache.rocketmq.common.message.Message;
+
+ public class ProducerExample {
+ public static void main(String[] args) throws Exception {
+ // 创建生产者实例，并设置生产者组名
+ DefaultMQProducer producer = new
DefaultMQProducer("please_rename_unique_group_name");
+ // 设置 Name Server 地址，此处为示例，实际使用时请替换为真实的 Name Server 地址
+ producer.setNamesrvAddr("localhost:9876");
+ producer.start();
+
+ try {
+ // 创建消息实例，指定 topic、Tag和消息体
+ Message msg = new Message("TestTopic", "TagA", ("Hello
RocketMQ").getBytes());
+ // 发送消息并获取发送结果
+ SendResult sendResult = producer.send(msg);
+ System.out.println("Message sent: " + new
String(msg.getBody()));
+ System.out.println("Send result: " + sendResult);
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.out.println("Message sending failed.");
+ } finally {
+ // 关闭生产者
+ producer.shutdown();
+ }
+ }
+ }
+ ```
+
+4. 在已创建的Java工程中，创建订阅普通消息程序并运行。Apache RocketMQ
有两种消费模式：**Push和Pull**，这里以Push消费为示例。
+
+ ```java
+ import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+ import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
+ import
org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
+ import
org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
+ import org.apache.rocketmq.common.message.Messag
Re: [PR] Add Docker-Compose deployment method to QuickStart guide for Version 4.x [rocketmq-site]
RongtongJin merged PR #644: URL: https://github.com/apache/rocketmq-site/pull/644 -- 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 #8222] Fix spelling errors in comments [rocketmq]
yx9o commented on PR #8224: URL: https://github.com/apache/rocketmq/pull/8224#issuecomment-2138917088 Hi @RongtongJin , I want to contribute to https://github.com/apache/rocketmq/wiki/RIP-10-RocketMQ-Unit-Test, how can I do it? -- 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] remote connect exception [rocketmq-dashboard]
panghu98525 commented on issue #181: URL: https://github.com/apache/rocketmq-dashboard/issues/181#issuecomment-2138819792 > I met this question when I started all by docker images. rockermq 4.8.0 I solved by: > > ```shell > docker run -d --name rocketmq-dashboard --link rmqnamesrv:namesrv -e "JAVA_OPTS=-Drocketmq.namesrv.addr=namesrv:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest > ``` use : docker run -d --net=host --name rocketmq-dashboard --link rmqnamesrv:namesrv -e "JAVA_OPTS=-Drocketmq.namesrv.addr=namesrv:9876" -t apacherocketmq/rocketmq-dashboard:latest -- 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 "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user RongtongJin (triggered by RongtongJin). Head commit for run: db163b431ea9366d1121d04ded4b660fd8a31624 / yuz10 <845238...@qq.com> Revert "[ISSUE #7757] Use `CompositeByteBuf` to prevent memory copy. (#7694)" (#8209) This reverts commit 7a36d4d736ae8d6d92658e3bdb18f1cd5c0afdb0. Report URL: https://github.com/apache/rocketmq/actions/runs/9297687006 With regards, GitHub Actions via GitBox
