Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

cserwen commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033738710 How to determine that 8 coroutines for consumption are generated @bogerv -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

bogerv commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033827068 ` func OrderPersistListDealing(_accountType string, _b string, _q string) { err := rocketmq.RMQ().Consumer(rocketmq.ConsumerGroupPersist).Subscribe( ro

Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

cserwen commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033836761 > ` func OrderPersistListDealing(_accountType string, _b string, _q string) { err := rocketmq.RMQ().Consumer(rocketmq.ConsumerGroupPersist).Subscribe( rocketmq.GetTopicPe

Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

bogerv commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033849433 > > ` func OrderPersistListDealing(_accountType string, _b string, _q string) { err := rocketmq.RMQ().Consumer(rocketmq.ConsumerGroupPersist).Subscribe( rocketmq.GetTopic

Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

cserwen commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033860392 This para only takes effect for concurrent consumption. For order consumption, each queue has one and only one coroutine to consume. @bogerv -- This is an aut

Re: [I] Using WithConsumeGoroutineNums in pushconsumer may not work as expected. [rocketmq-client-go]

bogerv commented on issue #1135: URL: https://github.com/apache/rocketmq-client-go/issues/1135#issuecomment-2033901185 > This param only takes effect for concurrent consumption. For order-consumption, each queue has one and only one coroutine to consume. So does this mean that if we

Re: [PR] Remove Synchronized Lock [rocketmq]

cserwen commented on PR #7912: URL: https://github.com/apache/rocketmq/pull/7912#issuecomment-2033927528 > It has been fixed in `develop` branch. 4.9.x only provides security patches or critical fixes, so this pr should be closed. Closed because of this @Tcytw -- This is an automa

Re: [PR] Remove Synchronized Lock [rocketmq]

cserwen closed pull request #7912: Remove Synchronized Lock URL: https://github.com/apache/rocketmq/pull/7912 -- 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-

[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 leizhiyuan (triggered by cserwen). Head commit for run: 23cede907dffcda98b3c7314e58fea94136fcb20 / leizhiyuan chore: revert some wrong code style Report URL: https://github.com/apache/

[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 leizhiyuan (triggered by cserwen). Head commit for run: 23cede907dffcda98b3c7314e58fea94136fcb20 / leizhiyuan chore: revert some wrong code style Report URL: https://github.com/apache/

[I] [Bug] Unable to consume messages in order while using RocketMQ 5 client [rocketmq]

CodingOX opened a new issue, #7999: URL: https://github.com/apache/rocketmq/issues/7999 ### 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 h

[I] add some info log in transactional messsage check [rocketmq]

wangjiao01 opened a new issue, #8000: URL: https://github.com/apache/rocketmq/issues/8000 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary In order to know expli

[I] add some info log in transactional messsage check [rocketmq]

wangjiao01 opened a new issue, #8001: URL: https://github.com/apache/rocketmq/issues/8001 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary In order to know expli

[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 cserwen). Head commit for run: 9f316429b4189018fce0570e918735f82970af1e / leizhiyuan fix: use skip to fix the findAny always first Report URL: https://githu

Re: [I] [Bug] Unable to consume messages orderly for ordered message while using RocketMQ 5 client [rocketmq]

3424672656 commented on issue #7999: URL: https://github.com/apache/rocketmq/issues/7999#issuecomment-2034898876 rocketmq currently only supports sequential consumption for a single queue -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [I] The incorrect incremental epoch when autoswitch ha. [rocketmq]

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

Re: [I] MappedFile#warmMappedFile there may be code that doesn't work [rocketmq]

github-actions[bot] closed issue #5571: MappedFile#warmMappedFile there may be code that doesn't work URL: https://github.com/apache/rocketmq/issues/5571 -- 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

Re: [I] The incorrect incremental epoch when autoswitch ha. [rocketmq]

github-actions[bot] closed issue #6505: The incorrect incremental epoch when autoswitch ha. URL: https://github.com/apache/rocketmq/issues/6505 -- 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 s

Re: [I] MappedFile#warmMappedFile there may be code that doesn't work [rocketmq]

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

[I] [Feature Request] Add `imagePullSecrets` to service account in operator helm chart [rocketmq-operator]

DavidSonoda opened a new issue, #221: URL: https://github.com/apache/rocketmq-operator/issues/221 **FEATURE REQUEST** 1. Please describe the feature you are requesting. Allow the operator helm chart to specify `imagePullSecrets` in the serviceAccount. 2. Provide any addi

[PR] [ISSUE #221] Add `imagePullSecrets` to operator helm chart SA [rocketmq-operator]

DavidSonoda opened a new pull request, #222: URL: https://github.com/apache/rocketmq-operator/pull/222 ## What is the purpose of the change Close #221. *Why*: When building operator image with different rocketmq version and pushed to private registry that requires auth, imagePullSe