Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2468682295 https://rocketmq.io/course/deploy/rocketmq_learning-gvr7dx_awbbpb_ogr2blaw8vy3tv14/?spm=0.29160081.0.0.630d5342Dzuczv#33-proxy-%E6%9C%AC%E5%9C%B0%E4%BB%A3%E7%90%86%E6%A8%A1%E5%BC%8F

Re: [I] [Bug] NET8.0环境下无法启动成功 [rocketmq-clients]

github-actions[bot] commented on issue #842: URL: https://github.com/apache/rocketmq-clients/issues/842#issuecomment-2469342778 This issue 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. -- This is an automated me

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469350575 - [proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java](https://github.com/apache/rocketmq/blob/rocketmq-all-5.3.1/proxy/src/main/java/org/apache/r

Re: [PR] diff 4.x and 5.x docs and sync some typos or description [rocketmq-site]

TianMing2018 commented on PR #703: URL: https://github.com/apache/rocketmq-site/pull/703#issuecomment-2468469088 By the way, here is three more problems I think we should viewed 1. the ports mentioned in `03Dashboard.md` and `04Dashboard.md` maybe outdated 2. the preview result was

Re: [PR] Set experimental_ui_max_stdouterr_bytes to 10MB in bazel [rocketmq]

universefeeler commented on PR #7348: URL: https://github.com/apache/rocketmq/pull/7348#issuecomment-2468565647 退订 At 2023-09-12 17:18:04, "Jixiang Jin" ***@***.***> wrote: Which Issue(s) This PR Fixes Fixes #issue_id Brief Description Set experiment

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2468771728 Caused by: java.lang.IllegalArgumentException: Message type is not specified also see -- This is an automated message from the Apa

Re: [PR] [#8859] Fix duplicate mapped file in mutil commitlog store path mode. [rocketmq]

hexueyuan commented on code in PR #8897: URL: https://github.com/apache/rocketmq/pull/8897#discussion_r1836274976 ## store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java: ## @@ -76,13 +82,14 @@ public MappedFile putRequestAndReturnMappedFile(String nextF

Re: [PR] [#8859] Fix duplicate mapped file in mutil commitlog store path mode. [rocketmq]

hexueyuan commented on code in PR #8897: URL: https://github.com/apache/rocketmq/pull/8897#discussion_r1836274976 ## store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java: ## @@ -76,13 +82,14 @@ public MappedFile putRequestAndReturnMappedFile(String nextF

[I] [Bug] Remove unnecessary jar files [rocketmq]

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

Re: [PR] [#8859] Fix duplicate mapped file in mutil commitlog store path mode. [rocketmq]

hexueyuan commented on code in PR #8897: URL: https://github.com/apache/rocketmq/pull/8897#discussion_r1836126949 ## store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java: ## @@ -76,13 +82,14 @@ public MappedFile putRequestAndReturnMappedFile(String nextF

[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 mawen12 (triggered by mawen12). Head commit for run: 6883fb509c7dd260e23fcdeacca43e3381d90864 / mawen12 <118196301...@gmail.com> handle string toUpper outside the loop Report URL: ht

[PR] diff 4.x and 5.x docs and sync some typos or description [rocketmq-site]

TianMing2018 opened a new pull request, #703: URL: https://github.com/apache/rocketmq-site/pull/703 Please do not create a Pull Request without creating an issue first. ## What is the purpose of the change diff 4.x and 5.x docs and sync some typos or description ## Brief

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

VictoryAnn commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469458288 > * [proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java](https://github.com/apache/rocketmq/blob/rocketmq-all-5.3.1/proxy/src/main/java/org/a

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469486041 嗯，对比了下这俩类的getTopicRouteForProxy方法 唯一的区别就是grpcPort和requestHostAndPortList ```java return new ProxyTopicRouteData(topicRouteData, grpcPort); // grpcPort是不带IP的啊，他

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469524469 嗯，唯一的区分就是local Proxy怎么定义了，按道理这里的local proxy的这个`叫法`有点让人`误解`，如果要是叫 broker 提供grpc协议入口会更合适。 即这个broker提供grpc协议又提供remoting协议。 这个和grpc的这个提供能力的叫法有关系，分离部署就叫proxy，合并启动就叫只负责自个的grpc

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

VictoryAnn commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469530013 > 嗯，唯一的区分就是local Proxy怎么定义了，按道理这里的local proxy的这个`叫法`有点让人`误解`，如果要是叫 broker 提供grpc协议入口会更合适。 > > 即这个broker提供grpc协议又提供remoting协议。 > > 这个和grpc的这个提供能力的叫法有关系，分离部署就叫proxy，合并

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

VictoryAnn commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469520324 个人感觉，topic路由相关的应该在proxy内部做掉，proxy的角色也是对外屏蔽掉broker和nameserver，proxy外层加负载均衡即可。 -- This is an automated message from the Apache Git Service. To respond to the message, please log o

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469527053 所以我怀疑local proxy 是用 grpc over remoting 替代了一个假设的存在（即原生的grpc能力） -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

VictoryAnn commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469503684 > 还是把proxy从 broker拆分部署吧，这个是没有问题的。入口不从namesrv，元信息就获取不到，local模式怪怪的。 local这块是感觉怪怪的，还有一个疑问点，local部署下，如果client不去获取topicRoute，直接sendmessage proxy是不是会自己转到其他的proxy，那这样client似乎没必要获取

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469494433 还是把proxy从 broker拆分部署吧，这个是没有问题的。入口不从namesrv，元信息就获取不到，local模式怪怪的。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[I] spring-cloud-starter-stream-rocketmq2023.0.1.0版本的延时消息不能被延时消费 [rocketmq-spring]

Dynasty-develop opened a new issue, #690: URL: https://github.com/apache/rocketmq-spring/issues/690 **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? 使用rocketmq的5.x版本的客户端以及使用rocketmq5.x服务端，并在springCloud微服务架构下使用rocketmq的自定义延

[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 hexueyuan (triggered by hexueyuan). Head commit for run: 7eb16fffec6bf7f118e3373df48e76c7647eb348 / TianMing2018 <2452146...@qq.com> fixed typo of RocketMQ_Example.md (#8905) fixed typo wor

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469551964 > > 嗯，唯一的区分就是local Proxy怎么定义了，按道理这里的local proxy的这个`叫法`有点让人`误解`，如果要是叫 broker 提供grpc协议入口会更合适。 > > 即这个broker提供grpc协议又提供remoting协议。 > > 这个和grpc的这个提供能力的叫法有关系，分离部署就叫proxy，合并启动就叫只负责自个的g

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

VictoryAnn commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469490723 我看是从这里cache获取的，cache是从nameserver获取的，proxy只是替换了端口（这里也存疑，cluster部署可能端口都是一致的，不会有问题。如果像local部署，不同的代理端口不同是不是也有问题？），不需要去访问其他机器。 ![image](https://github.com/user-attachments/assets/7

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469491662 grpcPort等同于仅仅包含了一个元素的List，所以相当于又过滤了？ -- 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 t

[I] [Bug] 当读队列1，写队列2时，推送报错：The value of "max" is out of range. [rocketmq-clients]

Jamlee opened a new issue, #866: URL: https://github.com/apache/rocketmq-clients/issues/866 ### 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).

Re: [I] [Bug] proxy local mode send message failed [rocketmq]

dyrnq commented on issue #8904: URL: https://github.com/apache/rocketmq/issues/8904#issuecomment-2469509440 第一个回答不了（非官方人员:( ） 第二个（作为用户）感觉有必要，毕竟proxy和namesrv类似的入口能力，像你这样划分topic的话，确实proxy需要知道topic具体落地到那个broker上，有点类似nginx的动态配置，比如/hello --->upstream 到后端，那么后端必须得能承接 /hello的访问，所以不管是namesrv或者pro

Re: [I] 5.x消息详情显示有问题 [rocketmq-dashboard]

mrwangyin commented on issue #248: URL: https://github.com/apache/rocketmq-dashboard/issues/248#issuecomment-2469699834 同样问题 -- 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.

Re: [PR] Override recoverOffsetTable for kvCq store [rocketmq]

LetLetMe closed pull request #8896: Override recoverOffsetTable for kvCq store URL: https://github.com/apache/rocketmq/pull/8896 -- 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.