Re: [PR] Fix spelling errors in words(rocketmq.msg_id) [rocketmq]
github-actions[bot] commented on PR #7474: URL: https://github.com/apache/rocketmq/pull/7474#issuecomment-2489798916 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, please leave a comment in this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] consumeExecutor use LinkedBlockingQueue which is not bounded as param of ThreadPoolExecutor [rocketmq]
github-actions[bot] commented on issue #5417: URL: https://github.com/apache/rocketmq/issues/5417#issuecomment-2489798967 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] consumeExecutor use LinkedBlockingQueue which is not bounded as param of ThreadPoolExecutor [rocketmq]
github-actions[bot] closed issue #5417: consumeExecutor use LinkedBlockingQueue which is not bounded as param of ThreadPoolExecutor URL: https://github.com/apache/rocketmq/issues/5417 -- 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 "Run Integration Tests" is working again!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: c13f051eb8deaecc00859028f2e9f398db32b454 / hqbfz <125714719+3424672...@users.noreply.github.com> Improve IO for asynchronous delivery processes (#8954) Co-authored-by: wanghuaiyuan Report URL: https://github.com/apache/rocketmq/actions/runs/11926021970 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8957] Remove excess traffic and fix cache inconsistencies [rocketmq]
3424672656 commented on PR #8958: URL: https://github.com/apache/rocketmq/pull/8958#issuecomment-2488530024 @lizhimins Excuse me,Is the design here for version compatibility or is there some other consideration -- 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 #8765] fix low performance of delay message when enable rocksdb consume queue [rocketmq]
lizhanhui commented on PR #8766: URL: https://github.com/apache/rocketmq/pull/8766#issuecomment-2487854123 > @lizhanhui I found no difference between batch and single get key from rocksdb. I will remove prefetch code. Batch: QueryCQ iter 10489877 cost 20527 QueryCQ iter 10489877 cost 19496 QueryCQ iter 10489877 cost 19395 > > Single: QueryCQ iter 10489877 cost 20313 QueryCQ iter 10489877 cost 19196 QueryCQ iter 10489877 cost 18945 Take a look at this blog, MultiGet has quite a few optimizations available, we shall have two options to investigate: 1, Simulated manual iterator with multi-get in the background, to prefetch accordingly; 2, Use RocksDB embedded Iterator; https://rocksdb.org/blog/2022/10/07/asynchronous-io-in-rocksdb.html -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: fce9a3f7650e7af1664cce974f5b3d74767dda82 / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11930435281 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583719 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/11930879258 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "License checker" failed!
The GitHub Actions job "License checker" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972930 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583718 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 qianye1001 (triggered by qianye1001). Head commit for run: 859782d42a409eeb11078293814b03785e8c3b11 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11930316148 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583707 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Run Integration Tests" failed!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972912 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972926 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/11931077630 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "License checker" failed!
The GitHub Actions job "License checker" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851151 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8929] Proxy adds message body empty check when send in grpc protocol. [rocketmq]
codecov-commenter commented on PR #8930: URL: https://github.com/apache/rocketmq/pull/8930#issuecomment-2488098884 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8930?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 `28.57143%` with `5 lines` in your changes missing coverage. Please review. > Project coverage is 47.67%. Comparing base [(`66ba456`)](https://app.codecov.io/gh/apache/rocketmq/commit/66ba4566f5ebaeac47c73eaaf4a86567e3760063?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) to head [(`859782d`)](https://app.codecov.io/gh/apache/rocketmq/commit/859782d42a409eeb11078293814b03785e8c3b11?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache). > Report is 15 commits behind head on develop. | [Files with missing lines](https://app.codecov.io/gh/apache/rocketmq/pull/8930?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/proxy/grpc/v2/producer/SendMessageActivity.java](https://app.codecov.io/gh/apache/rocketmq/pull/8930?src=pr&el=tree&filepath=proxy%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fproxy%2Fgrpc%2Fv2%2Fproducer%2FSendMessageActivity.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-cHJveHkvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL3JvY2tldG1xL3Byb3h5L2dycGMvdjIvcHJvZHVjZXIvU2VuZE1lc3NhZ2VBY3Rpdml0eS5qYXZh) | 0.00% | [1 Missing and 2 partials :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/8930?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | | [.../org/apache/rocketmq/proxy/config/ProxyConfig.java](https://app.codecov.io/gh/apache/rocketmq/pull/8930?src=pr&el=tree&filepath=proxy%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fproxy%2Fconfig%2FProxyConfig.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-cHJveHkvc3JjL21haW4vamF2YS9vcmcvYXBhY2hlL3JvY2tldG1xL3Byb3h5L2NvbmZpZy9Qcm94eUNvbmZpZy5qYXZh) | 50.00% | [2 Missing :warning: ](https://app.codecov.io/gh/apache/rocketmq/pull/8930?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#8930 +/- ## = + Coverage 47.63% 47.67% +0.03% - Complexity 1175611760 +4 = Files 1304 1304 Lines 9104691125 +79 Branches 1167211693 +21 = + Hits 4337043442 +72 + Misses 4234142314 -27 - Partials5335 5369 +34 ``` [:umbrella: View full report in Codecov by Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/8930?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). 🚨 Try these New Features: - [Flaky Tests Detection](https://docs.codecov.com/docs/test-result-ingestion-beta) - Detect and resolve failed and flaky tests -- 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 qianye1001 (triggered by github-actions[bot]). Head commit for run: 859782d42a409eeb11078293814b03785e8c3b11 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11930316148 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583719 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 yx9o (triggered by yx9o). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808867 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 github-actions[bot]). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808867 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: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808866 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Run Integration Tests" is working again!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has succeeded. Run started by GitHub user yx9o (triggered by yx9o). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808849 With regards, GitHub Actions via GitBox
[I] [Bug] Go SDK did not log to the home dir for some os [rocketmq-clients]
absolute8511 opened a new issue, #871: URL: https://github.com/apache/rocketmq-clients/issues/871 ### 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-clients/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub Discussions](https://github.com/apache/rocketmq-clients/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. ### Programming Language of the Client Go ### Runtime Platform Environment Mac, Linux ### RocketMQ Version of the Client/Server any ### Run or Compiler Version any ### Describe the Bug Go SDK did not log to the home dir for some os ### Steps to Reproduce Run on Mac ### What Did You Expect to See? Log should be write to the home dir ### What Did You See Instead? no logs under home dir. ### 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): 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/11930614348 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851147 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 qianye1001 (triggered by github-actions[bot]). Head commit for run: 859782d42a409eeb11078293814b03785e8c3b11 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11930316148 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972911 With regards, GitHub Actions via GitBox
[PR] [ISSUE #8961]automatic recognition of address scheme in topic route by host. [rocketmq]
dingshuangxi888 opened a new pull request, #8962: URL: https://github.com/apache/rocketmq/pull/8962 ### Which Issue(s) This PR Fixes Automatic recognition of address scheme in Topic Route by host. Fixes #8961 ### 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583710 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "License checker" failed!
The GitHub Actions job "License checker" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583709 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Run Integration Tests" failed!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583706 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583718 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: fce9a3f7650e7af1664cce974f5b3d74767dda82 / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11930435282 With regards, GitHub Actions via GitBox
[I] [Enhancement] Automatic recognition of address scheme in Topic Route by host. [rocketmq]
dingshuangxi888 opened a new issue, #8961: URL: https://github.com/apache/rocketmq/issues/8961 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Automatic recognition of address scheme in Topic Route by host. ### Motivation Automatic recognition of address scheme in Topic Route by host. ### Describe the Solution You'd Like Automatic recognition of address scheme in Topic Route by host. ### Describe Alternatives You've Considered Automatic recognition of address scheme in Topic Route by host. ### 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
[I] [Bug] the client can not handle the closed tcp without rst/fin [rocketmq-clients]
absolute8511 opened a new issue, #872: URL: https://github.com/apache/rocketmq-clients/issues/872 ### 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-clients/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub Discussions](https://github.com/apache/rocketmq-clients/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. ### Programming Language of the Client Java ### Runtime Platform Environment Any ### RocketMQ Version of the Client/Server Any ### Run or Compiler Version Any ### Describe the Bug If the tcp is closed abnormal without a fin or rst, the client will continue send request using the broken channel and will always timeout for a long time. We should turn on the keep alive for the grpc to detect this issue. ### Steps to Reproduce Drop the packets after tcp establish, the client will timeout for a long time. ### What Did You Expect to See? The client should try to create a new connection after keep alive timeout ### What Did You See Instead? the client will timeout for a long time and did not create a new connection ### 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): Workflow run "Run Integration Tests" is working again!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has succeeded. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: 859782d42a409eeb11078293814b03785e8c3b11 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11930316153 With regards, GitHub Actions via GitBox
[PR] [ISSUE #85] Exclude redundant Java dependencies in Bazel. [rocketmq-apis]
qianye1001 opened a new pull request, #91: URL: https://github.com/apache/rocketmq-apis/pull/91 [ISSUE #85] Exclude redundant Java dependencies in Bazel. -- 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851149 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Run Integration Tests" failed!
The GitHub Actions job "Run Integration Tests" on rocketmq.git has failed. Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851134 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851147 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972911 With regards, GitHub Actions via GitBox
[PR] feat: should add default keepalive for grpc channel [rocketmq-clients]
absolute8511 opened a new pull request, #870: URL: https://github.com/apache/rocketmq-clients/pull/870 Change-Id: Ie14d6990373cb011da3f4c60aef3ca280ed63819 ### Which Issue(s) This PR Fixes Fixes #issue_id ### 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 qianye1001 (triggered by qianye1001). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/1193034 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851146 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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972924 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: 500651e2c44319243608a421ce2cac42cfcad49e / dingshuangxi888 rollback remoting client Report URL: https://github.com/apache/rocketmq/actions/runs/11930851147 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 dingshuangxi888 (triggered by github-actions[bot]). Head commit for run: b33a89b8fa46c833667961d089996f2717ffebf1 / dingshuangxi888 Revert "rollback remoting client" This reverts commit 500651e2c44319243608a421ce2cac42cfcad49e. Report URL: https://github.com/apache/rocketmq/actions/runs/11930972911 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 yx9o (triggered by yx9o). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/11933847818 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "License checker" is working again!
The GitHub Actions job "License checker" on rocketmq.git has succeeded. Run started by GitHub user yx9o (triggered by yx9o). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808848 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8927] DLedger support LMQ [rocketmq]
bxfjb closed pull request #8928: [ISSUE #8927] DLedger support LMQ URL: https://github.com/apache/rocketmq/pull/8928 -- 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: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808853 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: d239d60e5742149f112489ef1281064b9a4faf7a / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11937337530 With regards, GitHub Actions via GitBox
(rocketmq) branch develop updated: [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936)
This is an automated email from the ASF dual-hosted git repository.
lizhimin 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 78575af0b8 [ISSUE #8935] Fix behind metrics unit error in timer
message store (#8936)
78575af0b8 is described below
commit 78575af0b8ddd409ea71facceb87c144951269ae
Author: Ji Juntao
AuthorDate: Tue Nov 19 17:35:10 2024 +0800
[ISSUE #8935] Fix behind metrics unit error in timer message store (#8936)
---
.../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index 32075474b9..071b1c0219 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1724,7 +1724,7 @@ public class TimerMessageStore {
public long getEnqueueBehindMillis() {
if (System.currentTimeMillis() - lastEnqueueButExpiredTime < 2000) {
-return (System.currentTimeMillis() -
lastEnqueueButExpiredStoreTime) / 1000;
+return System.currentTimeMillis() - lastEnqueueButExpiredStoreTime;
}
return 0;
}
[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 dingshuangxi888 (triggered by dingshuangxi888). Head commit for run: b44dd5570499cd76500523f3a8956b901274ea1d / dingshuangxi888 automatic recognition of address scheme in topic route by host. Report URL: https://github.com/apache/rocketmq/actions/runs/11930583719 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by qianye1001). Head commit for run: d239d60e5742149f112489ef1281064b9a4faf7a / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11937337535 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #8963] Fix code36 request sent to ns [rocketmq]
codecov-commenter commented on PR #8964: URL: https://github.com/apache/rocketmq/pull/8964#issuecomment-2488571680 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8964?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 47.67%. Comparing base [(`9202de3`)](https://app.codecov.io/gh/apache/rocketmq/commit/9202de34c30db004db26f4976f165595af1b8bd3?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) to head [(`b97f60f`)](https://app.codecov.io/gh/apache/rocketmq/commit/b97f60f8b604eabdf9fe07995891c02ac45f0efd?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#8964 +/- ## = - Coverage 47.68% 47.67% -0.01% + Complexity 1176111755 -6 = Files 1304 1304 Lines 9111891120 +2 Branches 1169211693 +1 = - Hits 4344843443 -5 + Misses 4229942298 -1 - Partials5371 5379 +8 ``` [:umbrella: View full report in Codecov by Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/8964?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). 🚨 Try these New Features: - [Flaky Tests Detection](https://docs.codecov.com/docs/test-result-ingestion-beta) - Detect and resolve failed and flaky tests -- 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 yx9o (triggered by yx9o). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808861 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 github-actions[bot]). Head commit for run: b97f60f8b604eabdf9fe07995891c02ac45f0efd / yx9o [ISSUE #8963] Fix code36 request sent to ns Report URL: https://github.com/apache/rocketmq/actions/runs/11933808853 With regards, GitHub Actions via GitBox
Re: [I] [Bug] broker java heap space [rocketmq]
yx9o commented on issue #8959: URL: https://github.com/apache/rocketmq/issues/8959#issuecomment-2488718475 Can you provide more information, such as jvm startup parameters, etc. -- 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] CONSUMER_SEND_MSG_BACK request may be sent to ns [rocketmq]
yx9o opened a new issue, #8963: URL: https://github.com/apache/rocketmq/issues/8963 ### 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 linux ### RocketMQ version all ### JDK Version jdk1.8 ### Describe the Bug In some scenarios, for example, - In master-slave mode, after the master fails, the slave node will consume data. If consumption fails, it will be sent back to the master broker. At this time, there is no master in the routing information, and the result is null. The request will be sent to ns. - In master-slave mode, when the master fails and recovers, the producer gets the routing information before the consumer. At this time, the producer sends data to the master, and the consumer consumes data on the slave node. If consumption fails, it will be sent back to the master broker. At this time, there is no master in the routing information, and the result is null. The request will be sent to ns. https://github.com/user-attachments/assets/4a142c5a-3c05-4761-907a-23b117659378";> https://github.com/user-attachments/assets/2a800df7-8eed-4d34-b9b2-af4bc74bf2e1";> ### Steps to Reproduce In master-slave mode, simulated consumption fails and returns ConsumeConcurrentlyStatus.RECONSUME_LATER At this time, if you stop the master node, you will find that there is a request to send network ns. ### What Did You Expect to See? CONSUMER_SEND_MSG_BACK requests are only sent to brokers. ### What Did You See Instead? CONSUMER_SEND_MSG_BACK request is sent to ns. ### 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-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by lizhimins). Head commit for run: d239d60e5742149f112489ef1281064b9a4faf7a / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11937337535 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user qianye1001 (triggered by lizhimins). Head commit for run: d239d60e5742149f112489ef1281064b9a4faf7a / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11937337530 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 qianye1001 (triggered by qianye1001). Head commit for run: 9202de34c30db004db26f4976f165595af1b8bd3 / Humkum <1109939...@qq.com> [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Report URL: https://github.com/apache/rocketmq/actions/runs/11945254459 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CPP Coverage" failed!
The GitHub Actions job "CPP Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: bedcf25f10f17110874accee8eea012c9bb5b01c / qianye [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945414037 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" is working again!
The GitHub Actions job "Build" on rocketmq-clients.git has succeeded. Run started by GitHub user qianye1001 (triggered by lizhimins). Head commit for run: d239d60e5742149f112489ef1281064b9a4faf7a / qianye f Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11937337530 With regards, GitHub Actions via GitBox
Re: [I] [Enhancement] Add validation of Message Body in Java Client [rocketmq-clients]
lizhimins closed issue #858: [Enhancement] Add validation of Message Body in Java Client URL: https://github.com/apache/rocketmq-clients/issues/858 -- 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-clients) branch master updated: [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new bedcf25f [ISSUE #858] Jave client validate Message Body to avoid
setting empty Body (#859)
bedcf25f is described below
commit bedcf25f10f17110874accee8eea012c9bb5b01c
Author: qianye
AuthorDate: Thu Nov 21 10:25:13 2024 +0800
[ISSUE #858] Jave client validate Message Body to avoid setting empty Body
(#859)
---
java/client-shade/pom.xml | 4 +--
java/client/pom.xml| 4 +--
.../java/exception/PayloadEmptyException.java | 29 ++
.../client/java/exception/StatusChecker.java | 2 ++
.../client/java/message/MessageBuilderImpl.java| 3 ++-
java/pom.xml | 24 +-
6 files changed, 43 insertions(+), 23 deletions(-)
diff --git a/java/client-shade/pom.xml b/java/client-shade/pom.xml
index ff8a9780..5dc223ea 100644
--- a/java/client-shade/pom.xml
+++ b/java/client-shade/pom.xml
@@ -42,8 +42,8 @@
rocketmq-client-java-noshade
-org.apache.tomcat
-annotations-api
+jakarta.annotation
+jakarta.annotation-api
diff --git a/java/client/pom.xml b/java/client/pom.xml
index a3ea357e..3c8ceb49 100644
--- a/java/client/pom.xml
+++ b/java/client/pom.xml
@@ -45,8 +45,8 @@
rocketmq-proto
-org.apache.tomcat
-annotations-api
+jakarta.annotation
+jakarta.annotation-api
io.grpc
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/exception/PayloadEmptyException.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/exception/PayloadEmptyException.java
new file mode 100644
index ..36be7b80
--- /dev/null
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/exception/PayloadEmptyException.java
@@ -0,0 +1,29 @@
+/*
+ * 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.client.java.exception;
+
+import org.apache.rocketmq.client.apis.ClientException;
+
+/**
+ * Generic exception represents that the request entity is empty.
+ */
+public class PayloadEmptyException extends ClientException {
+public PayloadEmptyException(int responseCode, String requestId, String
message) {
+super(responseCode, requestId, message);
+}
+}
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java
index 76f5a225..58e9cfc0 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java
@@ -79,6 +79,8 @@ public class StatusChecker {
case PAYLOAD_TOO_LARGE:
case MESSAGE_BODY_TOO_LARGE:
throw new PayloadTooLargeException(codeNumber, requestId,
statusMessage);
+case MESSAGE_BODY_EMPTY:
+throw new PayloadEmptyException(codeNumber, requestId,
statusMessage);
case TOO_MANY_REQUESTS:
throw new TooManyRequestsException(codeNumber, requestId,
statusMessage);
case REQUEST_HEADER_FIELDS_TOO_LARGE:
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
index 83cbb30c..f5a066b2 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java
@@ -27,6 +27,7 @@ import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.regex.Pattern;
+import org.apache.commons.lang3.ArrayUtils;
import org.apache.commons.lang3.StringUtils;
import org.ap
[GH] (rocketmq-clients): Workflow run "go_modules in /golang for google.golang.org/grpc - Update #920315893" failed!
The GitHub Actions job "go_modules in /golang for google.golang.org/grpc - Update #920315893" on rocketmq-clients.git has failed. Run started by GitHub user dependabot[bot] (triggered by dependabot[bot]). Head commit for run: bedcf25f10f17110874accee8eea012c9bb5b01c / qianye [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945414889 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 qianye1001 (triggered by github-actions[bot]). Head commit for run: 0bb04afb1b60f9aac8928024a88338ac86551345 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11945206843 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 qianye1001 (triggered by qianye1001). Head commit for run: 0bb04afb1b60f9aac8928024a88338ac86551345 / qianye fix pom Report URL: https://github.com/apache/rocketmq/actions/runs/11945206843 With regards, GitHub Actions via GitBox
(rocketmq-clients) branch master updated: [ISSUE #8870] Correct reported language code in nodejs client (#853)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new f5e2d20b [ISSUE #8870] Correct reported language code in nodejs client
(#853)
f5e2d20b is described below
commit f5e2d20b280457f07f96b1d2822aa6b36cf2950c
Author: zhaohai <33314633+zhaohai...@users.noreply.github.com>
AuthorDate: Thu Nov 21 10:28:19 2024 +0800
[ISSUE #8870] Correct reported language code in nodejs client (#853)
---
nodejs/src/client/BaseClient.ts | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/nodejs/src/client/BaseClient.ts b/nodejs/src/client/BaseClient.ts
index 77f790b9..520d62f4 100644
--- a/nodejs/src/client/BaseClient.ts
+++ b/nodejs/src/client/BaseClient.ts
@@ -288,7 +288,7 @@ export abstract class BaseClient {
// language of client
// FIXME: java.lang.IllegalArgumentException: No enum constant
org.apache.rocketmq.remoting.protocol.LanguageCode.nodejs
//
https://github.com/apache/rocketmq/blob/master/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java
-metadata.set('x-mq-language', 'HTTP');
+metadata.set('x-mq-language', 'NODE_JS');
// version of client
metadata.set('x-mq-client-version', UserAgent.INSTANCE.version);
if (this.namespace) {
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: f5e2d20b280457f07f96b1d2822aa6b36cf2950c / zhaohai <33314633+zhaohai...@users.noreply.github.com> [ISSUE #8870] Correct reported language code in nodejs client (#853) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945448133 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Golang Coverage" failed!
The GitHub Actions job "Golang Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: f5e2d20b280457f07f96b1d2822aa6b36cf2950c / zhaohai <33314633+zhaohai...@users.noreply.github.com> [ISSUE #8870] Correct reported language code in nodejs client (#853) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945448122 With regards, GitHub Actions via GitBox
Re: [I] [Bug] broker java heap space [rocketmq]
noone6931 commented on issue #8959: URL: https://github.com/apache/rocketmq/issues/8959#issuecomment-2490162780 broker start up pararm: -server \ -Xms6g \ -Xmx6g \ -Xmn2g \ -XX:MaxMetaspaceSize=256m \ -XX:+UseConcMarkSweepGC \ -XX:+UseCMSCompactAtFullCollection \ -XX:+CMSClassUnloadingEnabled \ -XX:CMSInitiatingOccupancyFraction=70 \ -XX:+CMSScavengeBeforeRemark \ -XX:+UseCMSInitiatingOccupancyOnly \ -XX:CMSFullGCsBeforeCompaction=5 \ -XX:SurvivorRatio=8 \ -XX:MaxDirectMemorySize=15g \ -XX:NewSize=128m \ -XX:+PrintGCDetails \ -XX:+PrintGCTimeStamps \ -XX:+PrintGCDateStamps \ -XX:+PrintTenuringDistribution \ -Xloggc:/opt/logs/rmq_srv_gc.log \ -XX:+UseGCLogFileRotation \ -XX:NumberOfGCLogFiles=5 \ -XX:GCLogFileSize=30m \ -Djava.ext.dirs=/opt/jdk1.8.0_121/jre/lib/ext:/opt/rocketmq/lib \ -Duser.home=/opt/rocketmq broker.conf: deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH sendMessageThreadPoolNums=32 useReentrantLockWhenPutMessage=true waitTimeMillsInSendQueue=1000 transferMsgByHeap=false warmMapedFileEnable=true -- 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] chore: fix compile error in rust 1.81.0 [rocketmq-clients]
github-actions[bot] commented on PR #846: URL: https://github.com/apache/rocketmq-clients/pull/846#issuecomment-2489815258 This PR is stale because it has been open for 30 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, please leave a comment in this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [ISSUE #8870] Correct reported language code in nodejs client [rocketmq-clients]
lizhimins merged PR #853: URL: https://github.com/apache/rocketmq-clients/pull/853 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: bedcf25f10f17110874accee8eea012c9bb5b01c / qianye [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945414034 With regards, GitHub Actions via GitBox
Re: [I] rocketmq-client-cpp windows版本支持创建ipv6 offset目录吗 [rocketmq-client-cpp]
whdugh commented on issue #476: URL: https://github.com/apache/rocketmq-client-cpp/issues/476#issuecomment-2490283750 When I run the RocketClient on a Windows machine, I found that it couldn't create an IPv6 directory because the directory contains special characters. Tracing back to the code, I located that UtilAll::getLocalAddress() retrieves the hostname randomly. Do I need to modify the code for this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "Golang Coverage" failed!
The GitHub Actions job "Golang Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: bedcf25f10f17110874accee8eea012c9bb5b01c / qianye [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945414038 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Rust Coverage" failed!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: bedcf25f10f17110874accee8eea012c9bb5b01c / qianye [ISSUE #858] Jave client validate Message Body to avoid setting empty Body (#859) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945414041 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CPP Coverage" failed!
The GitHub Actions job "CPP Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: f5e2d20b280457f07f96b1d2822aa6b36cf2950c / zhaohai <33314633+zhaohai...@users.noreply.github.com> [ISSUE #8870] Correct reported language code in nodejs client (#853) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945448124 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Rust Coverage" failed!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: f5e2d20b280457f07f96b1d2822aa6b36cf2950c / zhaohai <33314633+zhaohai...@users.noreply.github.com> [ISSUE #8870] Correct reported language code in nodejs client (#853) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/11945448113 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 github-actions[bot]). Head commit for run: 127e7aa7dc9787789093601c7a84d0010c62e585 / lizhimins <707364...@qq.com> [ISSUE #8955] Fix message buffer not release and dispatch thread exit in tiered storage Report URL: https://github.com/apache/rocketmq/actions/runs/11948374080 With regards, GitHub Actions via GitBox
