[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: d60198f621baac54bffb981d7a797a04dfa0bb5a / rongtong [ISSUE #8239] Fix the issue of potential message loss after a crash

Re: [PR] #fix spelling mistakes about 'unknown' [rocketmq]

github-actions[bot] commented on PR #3989: URL: https://github.com/apache/rocketmq/pull/3989#issuecomment-2155712785 This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale,

Re: [PR] [ISSUE #1917] Specify executor to run CompletionStage [rocketmq]

github-actions[bot] commented on PR #1916: URL: https://github.com/apache/rocketmq/pull/1916#issuecomment-2155712806 This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale,

Re: [PR] change word UNKNOW to UNKNOWN [rocketmq]

github-actions[bot] commented on PR #4210: URL: https://github.com/apache/rocketmq/pull/4210#issuecomment-2155712775 This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale,

Re: [I] [Bug] If dns resolve controller address exception will update controllerAddresses to null [rocketmq]

github-actions[bot] commented on issue #6873: URL: https://github.com/apache/rocketmq/issues/6873#issuecomment-2155712757 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

Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]

YxAc commented on PR #279: URL: https://github.com/apache/rocketmq-mqtt/pull/279#issuecomment-2154840175 hi @DongyuanPan , i have updated this PR according to the review comments, pls take a look when you are free. Thx. -- This is an automated message from the Apache Git Service. To

Re: [PR] Support FIFO-Type SubGroup Add、Update and Query For V5 & V4 [rocketmq-dashboard]

1294566108 commented on PR #204: URL: https://github.com/apache/rocketmq-dashboard/pull/204#issuecomment-2154761131 1. Support FIFO-Type Query for RocketMQ 5.X (Remenber to switch version to RocketMQ 5.X in dashboard) 支持 RMQ 5.X 版本的 FIFO 类型的订阅组查询功能，如图所示，新增FIFO选项 ![20240607-202803

[PR] Support FIFO-Type SubGroup Add、Update and Query For V5 & V4 [rocketmq-dashboard]

1294566108 opened a new pull request, #204: URL: https://github.com/apache/rocketmq-dashboard/pull/204 ## What is the purpose of the change 1.Support FIFO-Type subscriptionGroup Query for RocketMQ 5.X 2.Support FIFO-Type subscriptionGroup Add & Update for RocketMQ 5.X -- This is an

[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 hakusai22 (triggered by hakusai22). Head commit for run: ee9f3d2a30f79b7e2ad5e30a91750014be90b96c / hakusai22 Merge branch 'apache:develop' into fix_typo_v2 Report URL:

[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 hakusai22 (triggered by hakusai22). Head commit for run: d60198f621baac54bffb981d7a797a04dfa0bb5a / rongtong [ISSUE #8239] Fix the issue of potential message loss after a crash under

[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 hakusai22 (triggered by hakusai22). Head commit for run: ee9f3d2a30f79b7e2ad5e30a91750014be90b96c / hakusai22 Merge branch 'apache:develop' into fix_typo_v2 Report URL:

Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]

YxAc commented on code in PR #279: URL: https://github.com/apache/rocketmq-mqtt/pull/279#discussion_r1630793092 ## mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java: ## @@ -181,6 +185,12 @@ public void write(Session session, Message message, int

Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]

YxAc commented on code in PR #279: URL: https://github.com/apache/rocketmq-mqtt/pull/279#discussion_r1630791168 ## mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java: ## @@ -47,6 +48,12 @@ public class DefaultChannelManager implements

Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]

YxAc commented on code in PR #279: URL: https://github.com/apache/rocketmq-mqtt/pull/279#discussion_r1630790862 ## mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java: ## @@ -61,6 +61,7 @@ public class ConnectConf { private boolean enableRetain =

Re: [PR] [ISSUE #246] feat: implement flow control [rocketmq-mqtt]

YxAc commented on code in PR #279: URL: https://github.com/apache/rocketmq-mqtt/pull/279#discussion_r1630789596 ## mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelManager.java: ## @@ -63,4 +63,35 @@ public interface ChannelManager { */ int

Re: [I] The message queue is not in assigned list [rocketmq-flink]

ping-cai commented on issue #107: URL: https://github.com/apache/rocketmq-flink/issues/107#issuecomment-2154250518 it seens do nothing! this brantch 'main-latest' still exist! who can help fix this problem RocketMQ Version:4.9.2 Flink Version: 1.15.2 problem details: Caused by:

[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 lizhimins (triggered by lizhimins). Head commit for run: d60198f621baac54bffb981d7a797a04dfa0bb5a / rongtong [ISSUE #8239] Fix the issue of potential message loss after a crash under