hanmz opened a new issue, #8059:
URL: https://github.com/apache/rocketmq/issues/8059
### Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement
rather than a bug/feature.
### Summary
There are some typos in Def
biningo commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074382794
The community is very divided on whether SYSTEM_BUSY should be retried. But
there is no retry in the latest version.
--
This is an automated message from the Apache Git Service.
T
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
failed.
Run started by GitHub user MR-gwh (triggered by RongtongJin).
Head commit for run:
77062b87fc91bd73641b6094a5b982c7e6f7b0f2 / MR_G <2044783...@qq.com>
[ISSUE #8055]remove unnecessary math.abs() method
Report URL:
RongtongJin commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074445945
From another perspective, semantically returning busy is indeed more
reasonable than error.
--
This is an automated message from the Apache Git Service.
To respond to the mess
humkum commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074461651
Generally speaking, page cache busy will only cause process write operations
to be suspended for a few seconds. Retrying here will not increase the pressure
on page cache synchroniza
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user hanmz (triggered by hanmz).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL:
yuz10 commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074471222
Maybe we can retry SYSTEM_BUSY by default. currently need to call
`producer.addRetryResponseCode(ResponseCode.SYSTEM_BUSY);
` to add to retry list
--
This is an automated message
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user MR-gwh (triggered by MR-gwh).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user hanmz (triggered by RongtongJin).
Head commit for run:
9cf519e1beaa6f22c50164f294faa6ca907c5714 / hanmz
Fix some typos in DefaultLitePullConsumer and LitePullConsumer
Report URL: https://github.com/apache/
biningo commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074489030
In my opinion:
1. If the MQ is a single broker node：retry is unreasonable.
2. If the MQ has multiple broker nodes：retry is reasonable.
And it's not possible to have on
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user MR-gwh (triggered by RongtongJin).
Head commit for run:
77062b87fc91bd73641b6094a5b982c7e6f7b0f2 / MR_G <2044783...@qq.com>
[ISSUE #8055]remove unnecessary math.abs() method
Report URL: https://github.com/a
humkum commented on issue #8057:
URL: https://github.com/apache/rocketmq/issues/8057#issuecomment-2074490200
The `consumerManageExecutor` is initialized as a newFixedThreadPool, which's
queue size is Integer.MAX_VALUE. What's the value do you want to set? And did
you meet some problems with
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user hanmz (triggered by RongtongJin).
Head commit for run:
9cf519e1beaa6f22c50164f294faa6ca907c5714 / hanmz
Fix some typos in DefaultLitePullConsumer and LitePullConsumer
Report URL: https
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user MR-gwh (triggered by RongtongJin).
Head commit for run:
77062b87fc91bd73641b6094a5b982c7e6f7b0f2 / MR_G <2044783...@qq.com>
[ISSUE #8055]remove unnecessary math.abs() method
Report URL:
redlsz commented on PR #7863:
URL: https://github.com/apache/rocketmq/pull/7863#issuecomment-2074552688
> @redlsz could you please re-run the CI tasks?
https://github.com/apache/rocketmq/actions/runs/8750479357/job/24014103256?pr=7863
--
This is an automated message from the Ap
fujian-zfj opened a new issue, #8061:
URL: https://github.com/apache/rocketmq/issues/8061
### 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
humkum commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074792389
> In my opinion:
>
> 1. If the MQ is a single broker node：retry is unreasonable.
> 2. If the MQ has multiple broker nodes：retry is reasonable.
>
> And it's not possibl
He-Pin opened a new issue, #8062:
URL: https://github.com/apache/rocketmq/issues/8062
### Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement
rather than a bug/feature.
### Summary
Add virtual thread support
He-Pin opened a new pull request, #8063:
URL: https://github.com/apache/rocketmq/pull/8063
### Which Issue(s) This PR Fixes
Fixes https://github.com/apache/rocketmq/issues/8062
### Brief Description
1. Add config for preferring the virtual thread,
`"r
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
e1b7acc80b22cf4c2a235d064dbaa2fd53bb5660 / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "PR-CI" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
e1b7acc80b22cf4c2a235d064dbaa2fd53bb5660 / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/runs
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
e1b7acc80b22cf4c2a235d064dbaa2fd53bb5660 / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
e1b7acc80b22cf4c2a235d064dbaa2fd53bb5660 / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
biningo commented on issue #8053:
URL: https://github.com/apache/rocketmq/issues/8053#issuecomment-2074834588
@RongtongJin So what do you think? I think the producer can retry
SYSTEM_BUSY by default. If the community agrees, I can start a new PR to fix
this issue.
--
This is an automate
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
64f3066ec45adf6f33496fd34b987852525b20ea / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
The GitHub Actions job "PR-CI" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
64f3066ec45adf6f33496fd34b987852525b20ea / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/runs
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
64f3066ec45adf6f33496fd34b987852525b20ea / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
succeeded.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
64f3066ec45adf6f33496fd34b987852525b20ea / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/a
The GitHub Actions job "PR-CI" on rocketmq.git has succeeded.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
ce04c6079c3b51930ab25360f7bd3b94be70a97c / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
fujian-zfj opened a new pull request, #8064:
URL: https://github.com/apache/rocketmq/pull/8064
### Which Issue(s) This PR Fixes
Fixes #8061
### Brief Description
I found a npe bug in method getAndCreateChannel.
It may caused by 'getAndCreateChannelAsync(ad
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user fujian-zfj (triggered by fujian-zfj).
Head commit for run:
b987b66f3ea44ffba3ee543052150fea70927c96 / zfj
fix npe
Report URL: https://github.com/apache/rocketmq/actions/runs/8816909915
With regards,
GitHu
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user fujian-zfj (triggered by fujian-zfj).
Head commit for run:
b987b66f3ea44ffba3ee543052150fea70927c96 / zfj
fix npe
Report URL: https://github.com/apache/rocketmq/actions/runs/8816909913
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user fujian-zfj (triggered by fujian-zfj).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Re
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
ce04c6079c3b51930ab25360f7bd3b94be70a97c / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
3d12a39e8f620c0c12290c9fd539ef3d557341ed / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
3d12a39e8f620c0c12290c9fd539ef3d557341ed / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
bxfjb opened a new issue, #8065:
URL: https://github.com/apache/rocketmq/issues/8065
### 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
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
ce04c6079c3b51930ab25360f7bd3b94be70a97c / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
b37d283793f4d77ec787a7e6292838783db54a8b / mxsm
[ISSUE #8044]Add Override annotation for AllocateMappedFileService#run (#8045)
Report URL
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
succeeded.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
9006d5375d81e950cd539437ba487112b61e469b / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/a
The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
9006d5375d81e950cd539437ba487112b61e469b / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apache/rocketmq/actions/r
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
3d12a39e8f620c0c12290c9fd539ef3d557341ed / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user He-Pin (triggered by He-Pin).
Head commit for run:
9006d5375d81e950cd539437ba487112b61e469b / He-Pin
feat: Add virtual thread support for consumers.
Report URL: https://github.com/apac
github-actions[bot] commented on issue #715:
URL:
https://github.com/apache/rocketmq-clients/issues/715#issuecomment-2076083523
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
github-actions[bot] closed issue #715: [Enhancement] java sdk
SimpleConsumerExample示例代码增加对receive方法的异常捕获
URL: https://github.com/apache/rocketmq-clients/issues/715
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user bxfjb (triggered by yuz10).
Head commit for run:
324e8a06be985bae9f491b5b6337592f857c48f3 / zhaoyuhan
fix tiered store delete empty topic NPE
Report URL: https://github.com/apache/rock
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user hanmz (triggered by RongtongJin).
Head commit for run:
9cf519e1beaa6f22c50164f294faa6ca907c5714 / hanmz
Fix some typos in DefaultLitePullConsumer and LitePullConsumer
Report URL: https
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user bxfjb (triggered by caigy).
Head commit for run:
324e8a06be985bae9f491b5b6337592f857c48f3 / zhaoyuhan
fix tiered store delete empty topic NPE
Report URL: https://github.com/apache/rock
He-Pin commented on code in PR #8063:
URL: https://github.com/apache/rocketmq/pull/8063#discussion_r1578935562
##
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java:
##
@@ -70,13 +72,14 @@ public
ConsumeMessageConcurrentlyServic
53 matches
Mail list logo
