Re: [I] [Enhancement] PopReviveService exit is slow while stopping the broker [rocketmq]
drpmma commented on issue #8246: URL: https://github.com/apache/rocketmq/issues/8246#issuecomment-2146826113 The `shouldRunPopRevive` field is responsible for shutting down the service, see https://github.com/apache/rocketmq/blob/7145964b4a8db5d29a0af51b352efa2c342122aa/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java#L2025-L2029 But the method is not invoked in shutting down. -- 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] No accessKey is configured [rocketmq]
gongxulei commented on issue #3115: URL: https://github.com/apache/rocketmq/issues/3115#issuecomment-2146837820 大写的无语 -- 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]SubRemotingServer will not scanResponseTable will leak ResponseFuture [rocketmq]
leizhiyuan opened a new issue, #8250: URL: https://github.com/apache/rocketmq/issues/8250 ### 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 every ### RocketMQ version develop ### JDK Version _No response_ ### Describe the Bug SubRemotingServer will not scanResponseTable will leak ResponseFuture ### Steps to Reproduce SubRemotingServer will not scanResponseTable will leak ResponseFuture ### What Did You Expect to See? SubRemotingServer scanResponseTable ### What Did You See Instead? scanResponseTable will not scan ### 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
[PR] [ISSUE #8250]SubRemotingServer need scanResponseTable [rocketmq]
leizhiyuan opened a new pull request, #8251: URL: https://github.com/apache/rocketmq/pull/8251 ### Which Issue(s) This PR Fixes Fixes #8250 ### Brief Description ### How Did You Test This Change? -- 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 leizhiyuan (triggered by leizhiyuan). Head commit for run: 7145964b4a8db5d29a0af51b352efa2c342122aa / dingshuangxi888 [ISSUE 8230] fix the acl for NotifyClientTerminationRequest because group can be null. (#8231) Report URL: https://github.com/apache/rocketmq/actions/runs/9363593034 With regards, GitHub Actions via GitBox
[I] rocketmq 5.x cannot view information such as the current consumer group online. [rocketmq-dashboard]
Changego opened a new issue, #199: URL: https://github.com/apache/rocketmq-dashboard/issues/199 Hello, we recently upgraded rocketmq5.x version, although we got the latest version through github, we still found that we can not view the consumer group online information.  -- 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
Re: [I] 5.+ edition rocketmq proxy and dashboard issue [rocketmq-dashboard]
Changego commented on issue #185: URL: https://github.com/apache/rocketmq-dashboard/issues/185#issuecomment-2146954117 Me too -- 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" is working again!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has succeeded. Run started by GitHub user leizhiyuan (triggered by leizhiyuan). Head commit for run: a6b26d148a8b3fe5b1c42e12193c87e5086d1f32 / leizhiyuan fix: SubRemotingServer need scanResponseTable Report URL: https://github.com/apache/rocketmq/actions/runs/9363550767 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8127]Optimize the metric calculation logic of the time wheel [rocketmq]
3424672656 commented on PR #8128: URL: https://github.com/apache/rocketmq/pull/8128#issuecomment-2147084338 @RongtongJin PTAL~ -- 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 #8140]Fix semaphore exception that failed halfway in the case of asynchrono… [rocketmq]
3424672656 commented on PR #8141: URL: https://github.com/apache/rocketmq/pull/8141#issuecomment-2147083246 @RongtongJin PTAL~ -- 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) tag tmp-dev-0401 created (now bf24ffde88)
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a change to tag tmp-dev-0401 in repository https://gitbox.apache.org/repos/asf/rocketmq.git at bf24ffde88 (commit) No new revisions were added by this update.
(rocketmq) tag tmp-dev-0604 created (now 7145964b4a)
This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a change to tag tmp-dev-0604 in repository https://gitbox.apache.org/repos/asf/rocketmq.git at 7145964b4a (commit) No new revisions were added by this update.
Re: [PR] [ISSUE #7263& ISSUE #7264] Fix to cleanup consumption offset data or topic consumerqueue on the standby node when execute command 'deleteSubGroup' or 'deleteTopic' [rocketmq]
zhiliatom commented on PR #7273: URL: https://github.com/apache/rocketmq/pull/7273#issuecomment-2147155750 lgtm -- 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] 4.9.4版本下，广播模式客户端中断消费 [rocketmq]
DestinyL opened a new issue, #8252: URL: https://github.com/apache/rocketmq/issues/8252 ### 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 RedHat 8.4 ### RocketMQ version 4.9.4 ### JDK Version 1.8 ### Describe the Bug 广播模式下，消费消息异常，然后catch到一个不完整堆栈的异常之后，消费消息就中断了  jstack查看线程，后续都为waiting，猜测是server端推送消息中断，客户端只是waiting等待消费，并没有锁的问题  广播模式推送消息机制是否有不完善的设计 ### Steps to Reproduce 偶发，不能直接复现 ### What Did You Expect to See? - ### What Did You See Instead? - ### 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
[PR] Proxy Support For Dashboard [rocketmq-dashboard]
1294566108 opened a new pull request, #200: URL: https://github.com/apache/rocketmq-dashboard/pull/200 ## What is the purpose of the change 1.Support Proxy-Module for rocketmq-V5 in dashboard 2.Support Proxy Basic-Config Query 3.Support Proxy Detail-Config Query 4.Support the appearance or disappearance of proxy modules in the control panel as v5 and v4 switch -- 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] Proxy Support For Dashboard [rocketmq-dashboard]
1294566108 commented on PR #200: URL: https://github.com/apache/rocketmq-dashboard/pull/200#issuecomment-2147457513 **1.If we switch to V5,Proxy Module will appear**  **2.If we switch to V4,Proxy Module will disappear**  **3.Query detail proxy config**  **4.Add proxy server**  **5.We can switch proxy server in proxyList**  -- 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] Add data block configuration and simplify code [rocketmq]
lby1119 opened a new pull request, #8253: URL: https://github.com/apache/rocketmq/pull/8253 Add data block configuration and simplify code -- 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] Runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq]
3424672656 opened a new issue, #8254: URL: https://github.com/apache/rocketmq/issues/8254 ### 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 centos ### RocketMQ version develop ### JDK Version 11 ### Describe the Bug   In DefaultMQProducer.class, when the semaphore size is reassigned, part of the semaphore may have been acquired, resulting in an actual semaphore greater than the semaphore measured value   ### Steps to Reproduce null ### What Did You Expect to See? Correct semaphore meter value ### What Did You See Instead? Incorrect semaphore meter value ### 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
Re: [I] [Enhancement] Optimize ProducerManager#registerProducer code [rocketmq]
github-actions[bot] closed issue #6844: [Enhancement] Optimize ProducerManager#registerProducer code URL: https://github.com/apache/rocketmq/issues/6844 -- 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] [Enhancement] Optimize ProducerManager#registerProducer code [rocketmq]
github-actions[bot] commented on issue #6844: URL: https://github.com/apache/rocketmq/issues/6844#issuecomment-2148605429 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: [PR] [ISSUE #5918]Fix MessageStoreConfig some typo [rocketmq]
github-actions[bot] commented on PR #5919: URL: https://github.com/apache/rocketmq/pull/5919#issuecomment-2148605455 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-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [ISSUE #5918]Fix MessageStoreConfig some typo [rocketmq]
github-actions[bot] closed pull request #5919: [ISSUE #5918]Fix MessageStoreConfig some typo URL: https://github.com/apache/rocketmq/pull/5919 -- 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] [Rocketmq-client-nodejs] Error: 1 CANCELLED: Call cancelled [rocketmq-clients]
github-actions[bot] closed issue #717: [Rocketmq-client-nodejs] Error: 1 CANCELLED: Call cancelled URL: https://github.com/apache/rocketmq-clients/issues/717 -- 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] [Rocketmq-client-nodejs] Error: 1 CANCELLED: Call cancelled [rocketmq-clients]
github-actions[bot] commented on issue #717: URL: https://github.com/apache/rocketmq-clients/issues/717#issuecomment-2148616122 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
[GH] (rocketmq): Workflow run "Snapshot Daily Release Automation" is working again!
The GitHub Actions job "Snapshot Daily Release Automation" on rocketmq.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 7145964b4a8db5d29a0af51b352efa2c342122aa / dingshuangxi888 [ISSUE 8230] fix the acl for NotifyClientTerminationRequest because group can be null. (#8231) Report URL: https://github.com/apache/rocketmq/actions/runs/9376082239 With regards, GitHub Actions via GitBox
Re: [PR] Support dashboard v4-v5 switch And query for v5 topic [rocketmq-dashboard]
RongtongJin commented on code in PR #198:
URL:
https://github.com/apache/rocketmq-dashboard/pull/198#discussion_r1626789974
##
src/main/resources/static/view/layout/_header.html:
##
@@ -47,6 +47,14 @@
Simplified Chinese
+
+{{'CHANGE_VERSION' | translate}}
+
+
+V5
Review Comment:
V5 换成 RocketMQ 5.x
V4 换成 RocketMQ 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: [PR] [ISSUE #8245]Fix typo in user_guide.md [rocketmq]
RongtongJin merged PR #8244: URL: https://github.com/apache/rocketmq/pull/8244 -- 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: [ISSUE #8245]Fix typo in user_guide.md
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 7558850df1 [ISSUE #8245]Fix typo in user_guide.md 7558850df1 is described below commit 7558850df1773ffa67abae4f1b2ceaa7d5060e09 Author: liuzc9 <90489940+liu...@users.noreply.github.com> AuthorDate: Wed Jun 5 09:10:56 2024 +0800 [ISSUE #8245]Fix typo in user_guide.md --- docs/cn/msg_trace/user_guide.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/cn/msg_trace/user_guide.md b/docs/cn/msg_trace/user_guide.md index 9cf139fd34..a04c2601f4 100644 --- a/docs/cn/msg_trace/user_guide.md +++ b/docs/cn/msg_trace/user_guide.md @@ -103,7 +103,7 @@ RocketMQ的消息轨迹特性支持两种存储轨迹数据的方式： ### 4.4 使用mqadmin命令发送和查看轨迹 - 发送消息 ```shell -./mqadmin sendMessage -m true --topic some-topic-name -n 127.0.0.1:9876 -p "your meesgae content" +./mqadmin sendMessage -m true --topic some-topic-name -n 127.0.0.1:9876 -p "your message content" ``` - 查询轨迹 ```shell
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user lby1119 (triggered by RongtongJin). Head commit for run: 9bb502daaa9ab9a93b8c90e056348ed132644658 / lby1119 <1134684...@qq.com> fix Report URL: https://github.com/apache/rocketmq/actions/runs/9370749844 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 lby1119 (triggered by lby1119). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9376587689 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 lby1119 (triggered by RongtongJin). Head commit for run: 9bb502daaa9ab9a93b8c90e056348ed132644658 / lby1119 <1134684...@qq.com> fix Report URL: https://github.com/apache/rocketmq/actions/runs/9370749847 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 lby1119 (triggered by RongtongJin). Head commit for run: 9bb502daaa9ab9a93b8c90e056348ed132644658 / lby1119 <1134684...@qq.com> fix Report URL: https://github.com/apache/rocketmq/actions/runs/9370749842 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 lby1119 (triggered by RongtongJin). Head commit for run: 9bb502daaa9ab9a93b8c90e056348ed132644658 / lby1119 <1134684...@qq.com> fix Report URL: https://github.com/apache/rocketmq/actions/runs/9370749839 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: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9376545929 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" is working again!
The GitHub Actions job "Coverage" on rocketmq.git has succeeded. Run started by GitHub user RongtongJin (triggered by RongtongJin). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9376545917 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 yx9o (triggered by yx9o). Head commit for run: dcee2b9fa7e9eddf82aab4d3a3adeee01b20f1bb / yx9o Merge branch 'refs/heads/develop' into dev-8227 Report URL: https://github.com/apache/rocketmq/actions/runs/9376809470 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 yx9o (triggered by yx9o). Head commit for run: dcee2b9fa7e9eddf82aab4d3a3adeee01b20f1bb / yx9o Merge branch 'refs/heads/develop' into dev-8227 Report URL: https://github.com/apache/rocketmq/actions/runs/9376809460 With regards, GitHub Actions via GitBox
[I] [Bug] 4.9.7版本多主多从集群 [rocketmq]
wolf27w opened a new issue, #8255:
URL: https://github.com/apache/rocketmq/issues/8255
### 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
运行平台是kubernetes中部署的多主多从集群
### RocketMQ version
rocketmq集群版本4.9.7
### JDK Version
openjdk1.8
### Describe the Bug
我在kubernetes中部署了一个rocketmq多主多从集群，在集群内部访问没有任何问题，但是我通过代理访问集群内部的rocketmq集群就会出现消息重复，线看一下我的集群
我的多主多从配置
broker-a.conf
```
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerEnableProxy=true
brokerId=0
namesrvAddr=mq-ns.ops.svc.cluster.local:9876
brokerIP1=192.168.6.93
defaultTopicQueueNums=4
#Whether to allow the broker to automatically create topics, it is
recommended to open offline and close online
autoCreateTopicEnable=true
#Whether to allow the broker to automatically create a subscription group,
it is recommended to start offline and close online
autoCreateSubscriptionGroup=true
listenPort=10911
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=30
destroyMapedFileInterval=12
redeleteHangedFileInterval=12
diskMaxUsedSpaceRatio=88
maxMessageSize=65536
flushCommitLogLeastPages=4
flushConsumeQueueLeastPages=2
flushCommitLogThoroughInterval=1
flushConsumeQueueThoroughInterval=6
checkTransactionMessageEnable=false
sendMessageThreadPoolNums=16
pullMessageThreadPoolNums=16
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
```
broker-b.conf
```
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
brokerEnableProxy=true
brokerIP1=192.168.6.93
namesrvAddr=mq-ns.ops.svc.cluster.local:9876
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
listenPort=10911
deleteWhen=04
fileReservedTime=120
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=30
destroyMapedFileInterval=12
redeleteHangedFileInterval=12
diskMaxUsedSpaceRatio=88
maxMessageSize=65536
flushCommitLogLeastPages=4
flushConsumeQueueLeastPages=2
flushCommitLogThoroughInterval=1
flushConsumeQueueThoroughInterval=6
checkTransactionMessageEnable=false
sendMessageThreadPoolNums=16
pullMessageThreadPoolNums=16
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
```
先看一下我的nodeport配置
我的nginx代理配置，在93上面
```
stream {
upstream prod-eft-link-mq9876 {
least_conn;
server 192.168.6.237:30740;
server 192.168.6.236:30740;
}
upstream prod-eft-link-mq10909 {
least_conn;
server 192.168.6.236:30532;
server 192.168.6.237:32727;
}
upstream prod-eft-link-mq10911 {
least_conn;
server 192.168.6.236:31213;
server 192.168.6.237:32742;
}
server {
listen 9876;#9876
proxy_pass prod-eft-link-mq9876;
}
server {
listen 10909;#10909
proxy_pass prod-eft-link-mq10909;
}
server {
listen 10911; #10911
proxy_pass prod-eft-link-mq10911;
}
}
```
### Steps to Reproduce
如果我在broker-a和broker-b的主节点里增加了brokerIP1=192.168.6.93配置，我就会消息里出现重复
如果我不在配置文件里增加brokerIP1=192.168.6.93，消息不重复了，但是我客户端通过nginx无法直接和rocketmq集群通信
### What Did You Expect to See?
我希望rocketmq集群可以实现客户端通过代理连接到rocketmq集群，并且消息也不会重复
### What Did You See Instead?
这里是我的yaml文件
```
cat broker-a.yaml
---
apiVersion: v1
data:
broker.conf: |-
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
namesrvAddr=mq-ns.ops.svc.cluster.local:9876
defaultTopicQueueNums=4
#Whether to allow the broker to automatically create topics, it is
recommended to open offline and close online
autoCreateTopicEnable=true
#Whether to allow the broker to automatically create a subscription
group, it is recommended to start offline and close online
autoCreateSubscriptionGroup=true
listenPort=10911
deleteWhen=04
f
[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: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9376831202 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 RongtongJin (triggered by RongtongJin). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9376545919 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #116] feat: support client event notification [rocketmq-mqtt]
ChangingFond commented on code in PR #283:
URL: https://github.com/apache/rocketmq-mqtt/pull/283#discussion_r1626832466
##
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/hook/ClientEventHookManagerImpl.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.rocketmq.mqtt.cs.hook;
+
+import com.google.common.base.Preconditions;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.Channel;
+import io.netty.handler.codec.mqtt.MqttFixedHeader;
+import io.netty.handler.codec.mqtt.MqttMessageType;
+import io.netty.handler.codec.mqtt.MqttPublishMessage;
+import io.netty.handler.codec.mqtt.MqttPublishVariableHeader;
+import io.netty.handler.codec.mqtt.MqttQoS;
+import org.apache.rocketmq.common.ThreadFactoryImpl;
+import org.apache.rocketmq.mqtt.common.hook.ClientEventHook;
+import org.apache.rocketmq.mqtt.common.hook.ClientEventHookManager;
+import org.apache.rocketmq.mqtt.common.hook.HookResult;
+import org.apache.rocketmq.mqtt.common.model.ClientEventMessage;
+import org.apache.rocketmq.mqtt.common.model.ClientEventType;
+import org.apache.rocketmq.mqtt.cs.channel.ChannelInfo;
+import org.apache.rocketmq.mqtt.cs.session.infly.MqttMsgId;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.net.InetSocketAddress;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import static
org.apache.rocketmq.mqtt.common.model.Constants.CLIENT_EVENT_BATCH_SIZE;
+import static
org.apache.rocketmq.mqtt.common.model.Constants.CLIENT_EVENT_ORIGIN_TOPIC;
+
+@Component
+public class ClientEventHookManagerImpl implements ClientEventHookManager {
+@Resource
+private MqttMsgId mqttMsgId;
+private static Logger logger =
LoggerFactory.getLogger(ClientEventHookManagerImpl.class);
+private ClientEventHook clientEventHook;
+private AtomicBoolean isAssembled = new AtomicBoolean(false);
+private LinkedBlockingQueue eventQueue = new
LinkedBlockingQueue<>(1);
+private ExecutorService executorService;
+
+@PostConstruct
+public void init() {
+executorService = new ThreadPoolExecutor(
+1,
+1,
+1,
+TimeUnit.MINUTES,
+new LinkedBlockingQueue<>(5000),
+new ThreadFactoryImpl("ClientEventHookManager_"));
+executorService.submit(new ClientEventHookExecution());
+}
+
+@Override
+public void addHook(ClientEventHook clientEventHook) {
+if (isAssembled.get()) {
+throw new IllegalArgumentException("ClientEventHook Was
Assembled");
+}
+this.clientEventHook = clientEventHook;
+isAssembled.set(true);
+}
+
+private class ClientEventHookExecution implements Runnable {
+@Override
+public void run() {
+while (true) {
+int eventBatchSize = CLIENT_EVENT_BATCH_SIZE;
+List eventMessages = new
ArrayList<>(eventBatchSize);
+
+try {
+// batch online offline events
+while (eventBatchSize-- > 0) {
+ClientEventMessage eventMessage = eventQueue.poll(10,
TimeUnit.MILLISECONDS);
+if (eventMessage != null) {
+eventMessages.add(eventMessage);
+}
+}
+if (eventMessages.isEmpty()) {
+continue;
+}
+
+// covert to mqtt message
+List eventPublishMessages =
toMqttMessage(eventMessages);
+CompletableFuture eventHookResult =
clientEventHook.doHook(eventPublishMessages);
+
[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 Mrhorse99 (triggered by RongtongJin). Head commit for run: 044ac92043e9398cdcead2ca862b3f6e5271d731 / Mrhorse99 <82942806+mrhors...@users.noreply.github.com> Merge branch 'apache:develop' into develop Report URL: https://github.com/apache/rocketmq/actions/runs/9334583081 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]
ChangingFond commented on code in PR #279:
URL: https://github.com/apache/rocketmq-mqtt/pull/279#discussion_r1626836891
##
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java:
##
@@ -61,6 +61,7 @@ public class ConnectConf {
private boolean enableRetain = false;
private boolean enableSubscriptionIdentifier = false;
private int topicAliasMaximum = 10;
+private int serverReceiveMaximum = 65535;
Review Comment:
why set to 65535？
##
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelManager.java:
##
@@ -63,4 +63,35 @@ public interface ChannelManager {
*/
int totalConn();
+/**
+ * Refills the publish receive quota for the given channel.
+ * This method is typically called after a publish acknowledgement or
other scenarios that refill the quota.
+ * @param channel The channel for which the quota needs to be refilled.
+ * @return true if the quota was successfully refilled, false otherwise.
+ */
+boolean publishReceiveRefill(Channel channel);
Review Comment:
extract these flow releated method into another class？
--
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] [ISSUE #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq]
3424672656 opened a new pull request, #8256: URL: https://github.com/apache/rocketmq/pull/8256 ### Which Issue(s) This PR Fixes Fixes #8254 ### Brief Description ### How Did You Test This Change? -- 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 #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq]
3424672656 closed pull request #8256: [ISSUE #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values URL: https://github.com/apache/rocketmq/pull/8256 -- 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] [Enhancement] PopReviveService exit is slow while stopping the broker [rocketmq]
absolute8511 commented on issue #8246: URL: https://github.com/apache/rocketmq/issues/8246#issuecomment-2148752381 It is called by https://github.com/apache/rocketmq/blob/7145964b4a8db5d29a0af51b352efa2c342122aa/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java#L1397 -- 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] [ISSUE #169] Fix duplicate message in the topic tab message list in the message menu for rocketmq5.x [rocketmq-dashboard]
boomboomxx opened a new pull request, #201: URL: https://github.com/apache/rocketmq-dashboard/pull/201 ## What is the purpose of the change Fix duplicate message in the topic tab message list in the message menu for rocketmq5.x and optimize imports -- 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 #169] Fix duplicate message in the topic tab message list in the message menu for rocketmq5.x [rocketmq-dashboard]
boomboomxx closed pull request #201: [ISSUE #169] Fix duplicate message in the topic tab message list in the message menu for rocketmq5.x URL: https://github.com/apache/rocketmq-dashboard/pull/201 -- 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] [ISSUE #169] duplicate message in the topic tab message list in the message menu for rocketmq5.x [rocketmq-dashboard]
boomboomxx opened a new pull request, #202: URL: https://github.com/apache/rocketmq-dashboard/pull/202 ## What is the purpose of the change duplicate message in the topic tab message list in the message menu for rocketmq5.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
[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: dcee2b9fa7e9eddf82aab4d3a3adeee01b20f1bb / yx9o Merge branch 'refs/heads/develop' into dev-8227 Report URL: https://github.com/apache/rocketmq/actions/runs/9376809464 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 3424672656 (triggered by 3424672656). Head commit for run: d1e728fd3f32e827a77985d43dd6b37d0925705d / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377437784 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9377443108 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 3424672656 (triggered by 3424672656). Head commit for run: d1e728fd3f32e827a77985d43dd6b37d0925705d / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377437792 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 3424672656 (triggered by 3424672656). Head commit for run: d1e728fd3f32e827a77985d43dd6b37d0925705d / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377437779 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377477425 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9377481526 With regards, GitHub Actions via GitBox
[PR] [ISSUE #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq]
3424672656 opened a new pull request, #8257: URL: https://github.com/apache/rocketmq/pull/8257 ### Which Issue(s) This PR Fixes Fixes #8254 ### Brief Description ### How Did You Test This Change? -- 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 "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377483929 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9377490950 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377483931 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377477424 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377477432 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377483928 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 3424672656 (triggered by 3424672656). Head commit for run: d1e728fd3f32e827a77985d43dd6b37d0925705d / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377437781 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377477427 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 3424672656 (triggered by 3424672656). Head commit for run: 71074e8a26ead5d0930f2d19633e3ed494357342 / wanghuaiyuan <3424672...@qq.com> fix fail test Report URL: https://github.com/apache/rocketmq/actions/runs/9377623650 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 3424672656 (triggered by 3424672656). Head commit for run: 84f086cf2caae3d434cf870936d8bf22c4e8b012 / wanghuaiyuan <3424672...@qq.com> Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values Report URL: https://github.com/apache/rocketmq/actions/runs/9377483932 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9377630706 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 3424672656 (triggered by 3424672656). Head commit for run: 71074e8a26ead5d0930f2d19633e3ed494357342 / wanghuaiyuan <3424672...@qq.com> fix fail test Report URL: https://github.com/apache/rocketmq/actions/runs/9377623653 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 3424672656 (triggered by 3424672656). Head commit for run: 71074e8a26ead5d0930f2d19633e3ed494357342 / wanghuaiyuan <3424672...@qq.com> fix fail test Report URL: https://github.com/apache/rocketmq/actions/runs/9377623655 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 3424672656 (triggered by 3424672656). Head commit for run: ad9580ef1594863489ae34592f7682e1e4289441 / wanghuaiyuan <3424672...@qq.com> adjust code typo Report URL: https://github.com/apache/rocketmq/actions/runs/9377661100 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 3424672656 (triggered by 3424672656). Head commit for run: 71074e8a26ead5d0930f2d19633e3ed494357342 / wanghuaiyuan <3424672...@qq.com> fix fail test Report URL: https://github.com/apache/rocketmq/actions/runs/9377623654 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" is working again!
The GitHub Actions job "Coverage" on rocketmq.git has succeeded. Run started by GitHub user 3424672656 (triggered by 3424672656). Head commit for run: ad9580ef1594863489ae34592f7682e1e4289441 / wanghuaiyuan <3424672...@qq.com> adjust code typo Report URL: https://github.com/apache/rocketmq/actions/runs/9377661098 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8254]Fix runtime modifications to semaphoreAsyncSendNum and semaphoreAsyncSendSize result in inaccurate actual semaphore values [rocketmq]
codecov-commenter commented on PR #8257: URL: https://github.com/apache/rocketmq/pull/8257#issuecomment-2148797503 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8257?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report Attention: Patch coverage is `67.90123%` with `26 lines` in your changes missing coverage. Please review. > Project coverage is 42.91%. Comparing base [(`7558850`)](https://app.codecov.io/gh/apache/rocketmq/commit/7558850df1773ffa67abae4f1b2ceaa7d5060e09?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) to head [(`ad9580e`)](https://app.codecov.io/gh/apache/rocketmq/commit/ad9580ef1594863489ae34592f7682e1e4289441?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache). | [Files](https://app.codecov.io/gh/apache/rocketmq/pull/8257?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Patch % | Lines | |---|---|---| | [...mq/client/impl/producer/DefaultMQProducerImpl.java](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&filepath=client%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fclient%2Fimpl%2Fproducer%2FDefaultMQProducerImpl.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-Y2xpZW50L3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9jbGllbnQvaW1wbC9wcm9kdWNlci9EZWZhdWx0TVFQcm9kdWNlckltcGwuamF2YQ==) | 51.42% | [13 Missing and 4 partials :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | | [.../apache/rocketmq/client/lock/ReadWriteCASLock.java](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&filepath=client%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fclient%2Flock%2FReadWriteCASLock.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-Y2xpZW50L3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9jbGllbnQvbG9jay9SZWFkV3JpdGVDQVNMb2NrLmphdmE=) | 70.00% | [2 Missing and 4 partials :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | | [...he/rocketmq/client/producer/DefaultMQProducer.java](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&filepath=client%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fclient%2Fproducer%2FDefaultMQProducer.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-Y2xpZW50L3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9jbGllbnQvcHJvZHVjZXIvRGVmYXVsdE1RUHJvZHVjZXIuamF2YQ==) | 88.46% | [3 Missing :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/8257?src=pr&el=tree&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#8257 +/- ## = - Coverage 42.93% 42.91% -0.02% - Complexity 1038410388 +4 = Files 1271 1272 +1 Lines 8878588851 +66 Branches 1141011414 +4 = + Hits 3811838133 +15 - Misses 4597046006 +36 - Partials4697 4712 +15 ``` [:umbrella: View full report in Codecov by Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/8257?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
[I] 怎么开启控制台网页登录？ [rocketmq-dashboard]
wind-gh opened a new issue, #203: URL: https://github.com/apache/rocketmq-dashboard/issues/203 使用docker镜像部署apacherocketmq/rocketmq-dashboard:latest 添加了rocketmq.config.loginRequired=true就302异常了       -- 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 "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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9377682750 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 3424672656 (triggered by 3424672656). Head commit for run: ad9580ef1594863489ae34592f7682e1e4289441 / wanghuaiyuan <3424672...@qq.com> adjust code typo Report URL: https://github.com/apache/rocketmq/actions/runs/9377661102 With regards, GitHub Actions via GitBox
Re: [I] [Doc] fix 'meesage' typo in user_guide.md [rocketmq]
yx9o commented on issue #8245: URL: https://github.com/apache/rocketmq/issues/8245#issuecomment-2148826092 Fixed by #8244. -- 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 Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user 3424672656 (triggered by 3424672656). Head commit for run: 49c9d1683d9079e85cb4a4fd73eeeb62e3b83e4f / wanghuaiyuan <3424672...@qq.com> increase test Report URL: https://github.com/apache/rocketmq/actions/runs/9378276455 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9378296647 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 yx9o (triggered by zhouxinyu). Head commit for run: dcee2b9fa7e9eddf82aab4d3a3adeee01b20f1bb / yx9o Merge branch 'refs/heads/develop' into dev-8227 Report URL: https://github.com/apache/rocketmq/actions/runs/9376809464 With regards, GitHub Actions via GitBox
Re: [I] vs2019 compile error [rocketmq-client-cpp]
HUHANK commented on issue #445: URL: https://github.com/apache/rocketmq-client-cpp/issues/445#issuecomment-2148882904 @yuntong613 hello, 你有详细的VS2019 编译 rocketmq-cpp-client 2.2.0 的说明文档吗？我这边编译遇到问题老是不成功 -- 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] vs2019 compile error [rocketmq-client-cpp]
yuntong613 commented on issue #445: URL: https://github.com/apache/rocketmq-client-cpp/issues/445#issuecomment-2148917069 @HUHANK 工程地址在这里，https://github.com/yuntong613/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
[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 3424672656 (triggered by 3424672656). Head commit for run: e439a8ff13e8d540e1a0b0839802ec747af993f4 / wanghuaiyuan <3424672...@qq.com> increase test Report URL: https://github.com/apache/rocketmq/actions/runs/9379104904 With regards, GitHub Actions via GitBox
Re: [PR] Support dashboard v4-v5 switch And query for v5 topic [rocketmq-dashboard]
1294566108 commented on PR #198: URL: https://github.com/apache/rocketmq-dashboard/pull/198#issuecomment-2148970428 已修改version名称 @RongtongJin  -- 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 3424672656 (triggered by 3424672656). Head commit for run: e439a8ff13e8d540e1a0b0839802ec747af993f4 / wanghuaiyuan <3424672...@qq.com> increase test Report URL: https://github.com/apache/rocketmq/actions/runs/9379104911 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 3424672656 (triggered by 3424672656). Head commit for run: 227f9b357dc4fa9507819fbbda343ac5e4b8fd23 / wanghuaiyuan <3424672...@qq.com> fix test Report URL: https://github.com/apache/rocketmq/actions/runs/9379244318 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9379130930 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 3424672656 (triggered by 3424672656). Head commit for run: e439a8ff13e8d540e1a0b0839802ec747af993f4 / wanghuaiyuan <3424672...@qq.com> increase test Report URL: https://github.com/apache/rocketmq/actions/runs/9379104903 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 3424672656 (triggered by 3424672656). Head commit for run: 47c1b3bd7a1ed195e04845379f5b249a9ef8b6bd / wanghuaiyuan <3424672...@qq.com> fix test Report URL: https://github.com/apache/rocketmq/actions/runs/9379318481 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 3424672656 (triggered by 3424672656). Head commit for run: 227f9b357dc4fa9507819fbbda343ac5e4b8fd23 / wanghuaiyuan <3424672...@qq.com> fix test Report URL: https://github.com/apache/rocketmq/actions/runs/9379244301 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9379270651 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 3424672656 (triggered by 3424672656). Head commit for run: 227f9b357dc4fa9507819fbbda343ac5e4b8fd23 / wanghuaiyuan <3424672...@qq.com> fix test Report URL: https://github.com/apache/rocketmq/actions/runs/9379244300 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 3424672656 (triggered by 3424672656). Head commit for run: 7558850df1773ffa67abae4f1b2ceaa7d5060e09 / liuzc9 <90489940+liu...@users.noreply.github.com> [ISSUE #8245]Fix typo in user_guide.md Report URL: https://github.com/apache/rocketmq/actions/runs/9379348492 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" is working again!
The GitHub Actions job "Coverage" on rocketmq.git has succeeded. Run started by GitHub user 3424672656 (triggered by 3424672656). Head commit for run: 47c1b3bd7a1ed195e04845379f5b249a9ef8b6bd / wanghuaiyuan <3424672...@qq.com> fix test Report URL: https://github.com/apache/rocketmq/actions/runs/9379318486 With regards, GitHub Actions via GitBox
