[PR] [ISSUE #8599] Throw exception when receiving GO_AWAY twice to close channel. [rocketmq]

2024-10-25 Thread via GitHub
qianye1001 opened a new pull request, #8862: URL: https://github.com/apache/rocketmq/pull/8862 ### Which Issue(s) This PR Fixes Fixes #8599 ### Brief Description 1. Throw exception when receiving GO_AWAY twice to close channel. 2. Throw exception when r

Re: [PR] [ISSUE #8829] feat: provide ConfigManagerV2 to make best uses of RocksDB [rocketmq]

2024-10-25 Thread via GitHub
lizhanhui commented on PR #8856: URL: https://github.com/apache/rocketmq/pull/8856#issuecomment-2437085299 > Hi, @lizhanhui , we have been using version v1 in the production environment, and it's likely that some community users are doing the same. From a code perspective, a compatibility u

[I] 请教,消费方式用法 [rocketmq-client-go]

2024-10-25 Thread via GitHub
eddatt opened a new issue, #1176: URL: https://github.com/apache/rocketmq-client-go/issues/1176 您好,我有以下使用场景: 多实例拉取消费,每条消息全局仅消费一次,并且顺序消费 比如有10条消息,ID:0-9,当前两个实例,希望每个实例能每次拉取都获得下一个全局未消费的消息,理想情况下,id 02468被一个实例消费,id 13579 被另一个实例消费 我按照文档尝试: 1.poll 方法:两个实例情况下,一直只会有一个实例在消费,另一个实例完全拿不到消

Re: [PR] [#8822]Double write cq, reduce unnecessary switches [rocketmq]

2024-10-25 Thread via GitHub
lollipopjin commented on code in PR #8823: URL: https://github.com/apache/rocketmq/pull/8823#discussion_r1814160072 ## broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java: ## @@ -3418,6 +3375,103 @@ private boolean validateBlackListConfigExist(Pro

[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-10-25 Thread GitBox
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: c6ddccfffb74dc7e8ba42ad20d0d755fd69c6110 / yx9o Merge branch 'refs/heads/develop' into dev-8852 Report URL: https://github.com/apache/roc

[GH] (rocketmq): Workflow run "E2E test for pull request" is working again!

2024-10-25 Thread GitBox
The GitHub Actions job "E2E test for pull request" on rocketmq.git has succeeded. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: 95b88ff8fcfecbd1942e1a35460f7417ee620673 / hqbfz <125714719+3424672...@users.noreply.github.com> [ISSUE #8442][RIP-70-3] Extra

Re: [PR] [OSPP2024]feat: support aliyun OSS Sink Connector [rocketmq-connect]

2024-10-25 Thread via GitHub
2011shenlin commented on code in PR #540: URL: https://github.com/apache/rocketmq-connect/pull/540#discussion_r1816199090 ## connectors/aliyun/rocketmq-connect-oss/README.md: ## @@ -0,0 +1,50 @@ +# rocketmq-connect-oss +* **rocketmq-connect-oss** 说明 +``` +Be responsible for cons

Re: [PR] [OSPP2024]feat: support aliyun OSS Sink Connector [rocketmq-connect]

2024-10-25 Thread via GitHub
2011shenlin commented on code in PR #540: URL: https://github.com/apache/rocketmq-connect/pull/540#discussion_r1816199090 ## connectors/aliyun/rocketmq-connect-oss/README.md: ## @@ -0,0 +1,50 @@ +# rocketmq-connect-oss +* **rocketmq-connect-oss** 说明 +``` +Be responsible for cons

Re: [PR] Zyh_ict_pr [rocketmq]

2024-10-25 Thread via GitHub
ShannonDing commented on PR #8795: URL: https://github.com/apache/rocketmq/pull/8795#issuecomment-2437371570 这个PR太大了,建议按照模块分别创建issue和PR,把优化的地方做个介绍,方便社区review。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[PR] [golang] Fixed go client MessageQueues not filtering slave broker [rocketmq-clients]

2024-10-25 Thread via GitHub
lixiang365 opened a new pull request, #852: URL: https://github.com/apache/rocketmq-clients/pull/852 ### Which Issue(s) This PR Fixes Fixes ### Brief Description Occasional errors CODE: INTERNAL_SERVER_ERROR, MESSAGE: org.apache.rocketmq.p

Re: [I] 生产者没有Python客户端代码示例 [rocketmq-clients]

2024-10-25 Thread via GitHub
github-actions[bot] closed issue #838: 生产者没有Python客户端代码示例 URL: https://github.com/apache/rocketmq-clients/issues/838 -- 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 unsubscr

Re: [I] 生产者没有Python客户端代码示例 [rocketmq-clients]

2024-10-25 Thread via GitHub
github-actions[bot] commented on issue #838: URL: https://github.com/apache/rocketmq-clients/issues/838#issuecomment-2439077354 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 respo

[GH] (rocketmq): Workflow run "Coverage" is working again!

2024-10-25 Thread GitBox
The GitHub Actions job "Coverage" on rocketmq.git has succeeded. Run started by GitHub user LetLetMe (triggered by LetLetMe). Head commit for run: 14688a417af119e854613233b3e7ffc13d885895 / LetLetMe Reduce unnecessary switches Report URL: https://github.com/apache/rocketmq/actions/runs/1149424

[I] How to set rocketmq-proxy access through k8s host nodeport [rocketmq]

2024-10-25 Thread via GitHub
liuxin638507 opened a new issue, #8864: URL: https://github.com/apache/rocketmq/issues/8864 ### 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]

[PR] [ISSUE #542] Fix connect runtime stats oom [rocketmq-connect]

2024-10-25 Thread via GitHub
VictoryAnn opened a new pull request, #543: URL: https://github.com/apache/rocketmq-connect/pull/543 ## What is the purpose of the change fix connect runtime stats bug. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

Re: [PR] [ISSUE #8599] Throw exception when receiving GO_AWAY twice to close channel. [rocketmq]

2024-10-25 Thread via GitHub
codecov-commenter commented on PR #8862: URL: https://github.com/apache/rocketmq/pull/8862#issuecomment-2437209260 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8862?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comment

Re: [PR] [ISSUE #6805] Support peek message in pop consumption mode [rocketmq]

2024-10-25 Thread via GitHub
github-actions[bot] closed pull request #6806: [ISSUE #6805] Support peek message in pop consumption mode URL: https://github.com/apache/rocketmq/pull/6806 -- 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

Re: [PR] [ISSUE #6805] Support peek message in pop consumption mode [rocketmq]

2024-10-25 Thread via GitHub
github-actions[bot] commented on PR #6806: URL: https://github.com/apache/rocketmq/pull/6806#issuecomment-2439066417 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 messa

[GH] (rocketmq): Workflow run "Snapshot Daily Release Automation" failed!

2024-10-25 Thread GitBox
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: 95b88ff8fcfecbd1942e1a35460f7417ee620673 / hqbfz <125714719+3424672...@users.noreply.github.com> [ISSUE #8442][RIP-70-3] Ex