Re: [D] org.apache.rocketmq.store.schedule.ScheduleMessageService.DeliverDelayedMessageTimerTask#messageTimeup [rocketmq]

2024-01-15 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: org.apache.rocketmq.store.schedule.ScheduleMessageService.DeliverDelayedMessageTimerTask#messageTimeup Here is a bitwise logic GitHub link: https://github.com/apache/rocketmq/discussions/7754#discussioncomment-8130553 This is an

[PR] Upgrade fastjson version [rocketmq-externals]

2024-01-15 Thread via GitHub
RongtongJin opened a new pull request, #931: URL: https://github.com/apache/rocketmq-externals/pull/931 ## What is the purpose of the change Upgrade fastjson version ## Brief changelog Upgrade fastjson version ## Verifying this change Follow

Re: [D] 集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况? [rocketmq]

2024-01-15 Thread via GitHub
GitHub user cserwen added a comment to the discussion: 集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况? RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的 - Rebalance 是最终一致,各个 consumer 会定时查询 Topic 分区信息和 订阅组消费者信息,来计算自己应该消费的队列 - 除了你提到的这些情况,还可能多个 consumer 的 clientID 一样,然后计算出相同的分区,也会重复,由于 push

Re: [PR] Upgrade fastjson version [rocketmq-externals]

2024-01-15 Thread via GitHub
ShannonDing merged PR #931: URL: https://github.com/apache/rocketmq-externals/pull/931 -- 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:

Re: [D] 集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况? [rocketmq]

2024-01-15 Thread via GitHub
GitHub user cserwen edited a comment on the discussion: 集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况? RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的 - Rebalance 是最终一致,除了服务端主动通知,各个 consumer 会定时查询 Topic 分区信息和消费者信息,来计算自己应该消费的队列 - 除了你提到的这些情况,还可能多个 consumer 的 clientID

Re: [D] centos7 编译rocketmq-5.0 cpp动态库方法 [rocketmq-clients]

2024-01-16 Thread via GitHub
GitHub user wedvefv edited a discussion: centos7 编译rocketmq-5.0 cpp动态库方法 # 环境centos7 # 安装gcc8.3.1 echo "###开始安装gcc8.3.1##" sudo yum install centos-release-scl sudo yum install devtoolset-8-gcc* scl enable devtoolset-8 bash source /opt/rh/devtoolset-8/enable

Re: [D] centos7 编译rocketmq-5.0 cpp动态库方法 [rocketmq-clients]

2024-01-16 Thread via GitHub
GitHub user wedvefv edited a discussion: centos7 编译rocketmq-5.0 cpp动态库方法 # 环境centos7 # 安装gcc8.3.1 echo "###开始安装gcc8.3.1##" sudo yum install centos-release-scl sudo yum install devtoolset-8-gcc* scl enable devtoolset-8 bash source /opt/rh/devtoolset-8/enable

Re: [D] JVM parameter configuration failure [rocketmq]

2024-01-17 Thread via GitHub
GitHub user MmringZee added a comment to the discussion: JVM parameter configuration failure Here's the first picture. ![20240117-184124](https://github.com/apache/rocketmq/assets/113001598/153e84bd-5545-48d0-9d04-43a1c2a02c1a) GitHub link:

Re: [D] 5.x 版本 proxy 默认的8080端口,可以自定义吗 [rocketmq]

2024-01-17 Thread via GitHub
GitHub user MaplePc added a comment to the discussion: 5.x 版本 proxy 默认的8080端口,可以自定义吗 There is an item `remotingListenPort` in that json file GitHub link: https://github.com/apache/rocketmq/discussions/7174#discussioncomment-8158468 This is an automatically sent email for

Re: [D] 5.x 版本 proxy 默认的8080端口,可以自定义吗 [rocketmq]

2024-01-17 Thread via GitHub
GitHub user MaplePc added a comment to the discussion: 5.x 版本 proxy 默认的8080端口,可以自定义吗 config in file `conf/rmq-proxy.json` and add option after command mqbroker `-pc $ROCKETMQ_HOME/conf/rmq-proxy.json` GitHub link: https://github.com/apache/rocketmq/discussions/7174#discussioncomment-8158431

Re: [D] 5.x 版本 proxy 默认的8080端口,可以自定义吗 [rocketmq]

2024-01-17 Thread via GitHub
GitHub user MmringZee added a comment to the discussion: 5.x 版本 proxy 默认的8080端口,可以自定义吗 Where can I see what parameters are configurable? GitHub link: https://github.com/apache/rocketmq/discussions/7174#discussioncomment-8165553 This is an automatically sent email for

Re: [D] 5.x 版本 proxy 默认的8080端口,可以自定义吗 [rocketmq]

2024-01-18 Thread via GitHub
GitHub user MaplePc added a comment to the discussion: 5.x 版本 proxy 默认的8080端口,可以自定义吗 It looks like there's no document to refer, and my file is below: ``` { "rocketMQClusterName": "DefaultCluster", "grpcServerPort": 8091, "remotingListenPort": 8090 } ``` You can edit it in need. GitHub

Re: [D] 5.x 版本 proxy 默认的8080端口,可以自定义吗 [rocketmq]

2024-01-18 Thread via GitHub
GitHub user MaplePc added a comment to the discussion: 5.x 版本 proxy 默认的8080端口,可以自定义吗 It looks like there's no document to refer, andmy file is below:{ "rocketMQClusterName": "DefaultCluster", "grpcServerPort": 8091, "remotingListenPort": 8090 } You can edit it in need. .. ***@***.***

Re: [D] JVM parameter configuration failure [rocketmq]

2024-01-18 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: JVM parameter configuration failure 这是虚拟内存 GitHub link: https://github.com/apache/rocketmq/discussions/7759#discussioncomment-8175754 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send

Re: [D] JVM parameter configuration failure [rocketmq]

2024-01-18 Thread via GitHub
GitHub user MmringZee added a comment to the discussion: JVM parameter configuration failure 但是虚拟内存也意味着rocketmq需要申请到那么多资源才能启动,即使不需要真实地使用。 我现在的场景就是需要在k8s里部署rocketmq,但是因为这个情况我发现我不得不把request设置得很大,这会占用掉很多的集群资源 T.T GitHub link:

Re: [D] JVM parameter configuration failure [rocketmq]

2024-01-18 Thread via GitHub
GitHub user MmringZee edited a comment on the discussion: JVM parameter configuration failure 但是虚拟内存也意味着rocketmq需要申请到那么多资源才能启动,即使不需要真实地使用。 我现在的场景就是需要在k8s里部署rocketmq,但是因为这个情况我发现我不得不把request设置得很大,这会占用掉很多的集群资源 T.T 我一开始尝试调整jvm参数并把request和limit设置成合理的1、2G甚至2、4G发现都没办法部署一直报OOM。后面在开发环境才发现内存占用量很高这个事情。

Re: [D] JVM parameter configuration failure [rocketmq]

2024-01-18 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: JVM parameter configuration failure 你直接在容器里面看 ps aux|grep java 看看jvm参数实际生效的是什么,我们在2C4G的容器里也能跑起来的 GitHub link: https://github.com/apache/rocketmq/discussions/7759#discussioncomment-8176143 This is an automatically sent email for

Re: [D] pop消费模式能保证消息顺序吗 [rocketmq]

2024-01-09 Thread via GitHub
GitHub user yzq-del added a comment to the discussion: pop消费模式能保证消息顺序吗 https://rocketmq.apache.org/zh/docs/featureBehavior/08consumerloadbalance GitHub link: https://github.com/apache/rocketmq/discussions/7692#discussioncomment-8074419 This is an automatically sent email for

Re: [D] pop消费模式能保证消息顺序吗 [rocketmq]

2024-01-09 Thread via GitHub
GitHub user yzq-del deleted a comment on the discussion: pop消费模式能保证消息顺序吗 怎样实现的? GitHub link: https://github.com/apache/rocketmq/discussions/7692#discussioncomment-7924010 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to:

Re: [D] pop消费模式能保证消息顺序吗 [rocketmq]

2024-01-09 Thread via GitHub
GitHub user yzq-del deleted a comment on the discussion: pop消费模式能保证消息顺序吗 https://rocketmq.apache.org/zh/docs/featureBehavior/08consumerloadbalance GitHub link: https://github.com/apache/rocketmq/discussions/7692#discussioncomment-8074419 This is an automatically sent email for

Re: [D] pop消费模式能保证消息顺序吗 [rocketmq]

2024-01-09 Thread via GitHub
GitHub user yzq-del added a comment to the discussion: pop消费模式能保证消息顺序吗 https://rocketmq.apache.org/zh/docs/featureBehavior/08consumerloadbalance GitHub link: https://github.com/apache/rocketmq/discussions/7692#discussioncomment-8074422 This is an automatically sent email for

Re: [D] add api reporting producer runninginfo to broker as consumer did [rocketmq]

2024-01-11 Thread via GitHub
GitHub user yp969803 added a comment to the discussion: add api reporting producer runninginfo to broker as consumer did @francisoliverlee can you tell me the properties and methods producreRunningInfo class should contain GitHub link:

Re: [D] 动态新增namesrv节点,导致客户端消息发送失败,No route info of this topic [rocketmq]

2023-12-19 Thread via GitHub
GitHub user Silencesk closed a discussion: 动态新增namesrv节点,导致客户端消息发送失败,No route info of this topic # 背景 * rocketmq:4.9.4,master-slave架构部署 * 在客户端Producer使用WSAddr(rocketmq.namesrv.domain/rocketmq.namesrv.domain.subgroup)来进行namesrv地址的动态刷新,这样可以发现新增的namesrv节点 * 客户端Producer以2000 tps发送消息 *

Re: [D] dledger模式下的mq集群,重启broker主从切换会出现消息丢失 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user LittleBoy18 added a comment to the discussion: dledger模式下的mq集群,重启broker主从切换会出现消息丢失 感谢你的回复,这个问题确认了是dledger broker在异常重启时index file可能会被删掉但是未被重建,导致根据msgId查询异常 GitHub link: https://github.com/apache/rocketmq/discussions/7476#discussioncomment-7896846 This is an automatically

Re: [D] dledger模式下的mq集群,重启broker主从切换会出现消息丢失 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user LittleBoy18 closed a discussion: dledger模式下的mq集群,重启broker主从切换会出现消息丢失 1、搭建的4.9.2版本的dledger集群,发送一批消息后,重启master broker模拟主从切换,切换后发现消息有丢失 https://github.com/apache/rocketmq/assets/18388649/e435216f-d3d2-4bd2-afc8-502eeb17137c;> GitHub link:

Re: [D] 事务消息回查相关疑问 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user LittleBoy18 closed a discussion: 事务消息回查相关疑问 事务消息回查是每个broker都会去定时执行的吗?如果两个broker同时对producer进行事务消息回查,是不是会造成producer commit两次造成broker上有重复的数据? GitHub link: https://github.com/apache/rocketmq/discussions/7350 This is an automatically sent email for dev@rocketmq.apache.org. To

Re: [D] rocketmq集群开启自动创建topic无效 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user dx8439 closed a discussion: rocketmq集群开启自动创建topic无效 rocketmq集群开启自动创建topic,autoCreateTopicEnable=true,版本4.6.1,但是,但是服务发送消息报错没有topic。 See http://rocketmq.apache.org/docs/faq/ for further details. at com.runjing.rocketmq.RocketMQProducer.defaultSend(RocketMQProducer.java:83)

Re: [D] rocketmq集群开启自动创建topic无效 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user RongtongJin closed the discussion with a comment: rocketmq集群开启自动创建topic无效 TBW102正常权限应该为7 GitHub link: https://github.com/apache/rocketmq/discussions/7588#discussioncomment-7896603 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send

Re: [D] rocketmq topic perm的值在什么情况下会被修改 [rocketmq]

2023-12-19 Thread via GitHub
GitHub user LittleBoy18 closed a discussion: rocketmq topic perm的值在什么情况下会被修改 环境:在openshift环境中通过pod部署,使用了类似nfs的远程存储 版本:5.1.0 反复重启broker pod,发生了broker重新调度到其他节点,会出现topic perm值被修改为4的情况 GitHub link: https://github.com/apache/rocketmq/discussions/7595 This is an automatically sent email for

Re: [D] rocketmq index文件什么条件下会触发delete [rocketmq]

2023-12-19 Thread via GitHub
GitHub user LittleBoy18 closed a discussion: rocketmq index文件什么条件下会触发delete ![image](https://github.com/apache/rocketmq/assets/18388649/c68e64ae-4096-4ca3-803f-84dde866260c) 在k8s上部署了dledger模式的mq,每次删除Pod重启index文件都会被清理,根据msgId查询不到旧消息 GitHub link:

Re: [D] [5.1.0]关于Dledger和controller疑问 [rocketmq]

2023-12-28 Thread via GitHub
GitHub user drivebyer added a comment to the discussion: [5.1.0]关于Dledger和controller疑问 > DLedger Controller宕机两个节点后由于达不到Raft多数派的要求无法再协助Broker切换 大佬们。关于这点,假设有 3 个 controller 节点,部署在 2 个机房。 如果多数派的机房宕机后,理论上来说 raft 集群是无法正常工作了,这时候是否有什么办法强制让剩余的一个 controller 节点提供主从切换的功能呢? GitHub link:

Re: [I] Is there an official ARM image? [rocketmq-docker]

2023-12-05 Thread via GitHub
Flora945 commented on issue #77: URL: https://github.com/apache/rocketmq-docker/issues/77#issuecomment-1840401416 want official ARM64 image too  -- 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

[I] need support arm64 [rocketmq-docker]

2023-11-29 Thread via GitHub
vearne opened a new issue, #98: URL: https://github.com/apache/rocketmq-docker/issues/98 The issue tracker is **ONLY** used for bug report(feature request need to follow [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal)). Keep in mind, please check

Re: [I] 作为一个中国人开源的项目,就不能留个中文的文档吗? [rocketmq-docker]

2023-11-29 Thread via GitHub
vearne closed issue #97: 作为一个中国人开源的项目,就不能留个中文的文档吗? URL: https://github.com/apache/rocketmq-docker/issues/97 -- 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,

[I] 作为一个中国人开源的项目,就不能留个中文的文档吗? [rocketmq-docker]

2023-11-29 Thread via GitHub
vearne opened a new issue, #97: URL: https://github.com/apache/rocketmq-docker/issues/97 The issue tracker is **ONLY** used for bug report(feature request need to follow [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal)). Keep in mind, please check

Re: [I] possible memory leak [rocketmq-client-python]

2023-11-29 Thread via GitHub
qykong commented on issue #96: URL: https://github.com/apache/rocketmq-client-python/issues/96#issuecomment-1833224387 We recently encountered a bug while utilizing the Python SDK, installed via pip. To assist others who might face the same issue, it would be highly beneficial if this fix

Re: [I] ERROR: failed to solve: eclipse-temurin:8-jdk-alpine: no match for platform in manifest [rocketmq-docker]

2023-11-22 Thread via GitHub
YuanHuaQiang commented on issue #89: URL: https://github.com/apache/rocketmq-docker/issues/89#issuecomment-1823762746 So did I -- 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

Re: [D] 5.1.3消息堆积较多后,消费性能会特别差,有同学遇到过吗 [rocketmq]

2024-02-01 Thread via GitHub
GitHub user iamqq23ue edited a discussion: 5.1.3消息堆积较多后,消费性能会特别差,有同学遇到过吗 我一台32G的虚拟机,大约堆积2000万的1k消息以后,消费的性能就特别差了。最低只有几千。 理论上可能是消息不在内存中,消费性能差,但是差的有点多了。新版本好像解决了,但是没有看到5.1.4有相应的版本说明。 GitHub link: https://github.com/apache/rocketmq/discussions/7810 This is an automatically sent email for

Re: [D] 自定义sendMessageHook被执行多次? [rocketmq]

2024-01-31 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: 自定义sendMessageHook被执行多次? 使用了异步发送?异步发送的时候,hook确实会执行两次,异步里面一次,外面一次,但是外面因为sendResult为空,所以实际上执行了进去会直接跳出。 GitHub link: https://github.com/apache/rocketmq/discussions/7518#discussioncomment-8331088 This is an automatically sent email

Re: [D] 自定义sendMessageHook被执行多次? [rocketmq]

2024-02-01 Thread via GitHub
GitHub user dousp added a comment to the discussion: 自定义sendMessageHook被执行多次? 应该是异步发送,回头我再调试看下。 GitHub link: https://github.com/apache/rocketmq/discussions/7518#discussioncomment-827 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-21 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? 什么意思? 是说在A系统的controller里面,吧消息投递到消息队列,然后在B系统里收消息,然后进行处理?处理完成后,希望A的controller再返回? GitHub link: https://github.com/apache/rocketmq/discussions/7767#discussioncomment-8203633

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-21 Thread via GitHub
GitHub user Conmi-WhiteJoker edited a comment on the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? 是的,我想controller作为生产者提交数据到rocketmq,同时能实时响应消费者处理完成后的返回数据。或者设置一个超时时间,超过了就跳过监听返回数据 GitHub link:

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-21 Thread via GitHub
GitHub user Conmi-WhiteJoker added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? 是的,我想controller能实时响应消费者处理完成后的返回数据 GitHub link: https://github.com/apache/rocketmq/discussions/7767#discussioncomment-8203664 This is an automatically sent email

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user cserwen added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? +1,确实没有必要用消息队列,但是非要用的话,可以用 “Request-Reply” 发送 https://github.com/apache/rocketmq/blob/develop/broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user Conmi-WhiteJoker added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? > 你这个场景没必要使用消息,而且生产者也并不知道消费者消费完,因为有可能有多个消费组。吧消息的解耦又想变成耦合。没有实际意义感觉。

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? 你这种不如吧controller改造成一个异步接口,进来发完消息,就返回accept,然后你下游处理完成后,再回调上游的一个接口来更新结果。 如果不行,就是 @cserwen 说的,参考 https://www.cnblogs.com/yunqishequ/p/12511391.html 这个看看这种用法,

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user Conmi-WhiteJoker added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? > 你这种不如吧controller改造成一个异步接口,进来发完消息,就返回accept,然后你下游处理完成后,再回调上游的一个接口来更新结果。 > > 如果不行,就是 @cserwen 说的,参考 https://www.cnblogs.com/yunqishequ/p/12511391.html > 这个看看这种用法,

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-21 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? 你这个场景没必要使用消息,而且生产者也并不知道消费者消费完,因为有可能有多个消费组。吧消息的解耦又想变成耦合。没有实际意义感觉。 GitHub link: https://github.com/apache/rocketmq/discussions/7767#discussioncomment-8205183 This is an

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user Conmi-WhiteJoker added a comment to the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?

Re: [D] 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法? [rocketmq]

2024-01-22 Thread via GitHub
GitHub user Conmi-WhiteJoker deleted a comment on the discussion: 如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?

Re: [D] fastjson漏洞整改 [rocketmq]

2024-01-30 Thread via GitHub
GitHub user coolqz added a comment to the discussion: fastjson漏洞整改 好的,谢谢 GitHub link: https://github.com/apache/rocketmq/discussions/7800#discussioncomment-8300430 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to:

Re: [D] fastjson漏洞整改 [rocketmq]

2024-01-29 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: fastjson漏洞整改 你可以自己升级 到 [1.2.83](https://mvnrepository.com/artifact/com.alibaba/fastjson/1.2.83) 这个没漏洞的版本 GitHub link: https://github.com/apache/rocketmq/discussions/7800#discussioncomment-8295726 This is an automatically

Re: [D] fastjson漏洞整改 [rocketmq]

2024-01-29 Thread via GitHub
GitHub user coolqz added a comment to the discussion: fastjson漏洞整改 是直接将rocketmq安装目录下lib目录的fastjson的jar包替换成1.2.83的,然后重启broker和namesrv就行了吗 GitHub link: https://github.com/apache/rocketmq/discussions/7800#discussioncomment-8295887 This is an automatically sent email for

Re: [D] fastjson漏洞整改 [rocketmq]

2024-01-29 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: fastjson漏洞整改 你如果是直接把开源的包拿去部署,不是自己编译,是可以这么做的,吧lib替换一下就可以。线下环境验证下就行。 GitHub link: https://github.com/apache/rocketmq/discussions/7800#discussioncomment-8295978 This is an automatically sent email for dev@rocketmq.apache.org. To

Re: [D] QuickStart Demo ERROR: Task was cancelled. [rocketmq]

2024-01-31 Thread via GitHub
GitHub user MmringZee added a comment to the discussion: QuickStart Demo ERROR: Task was cancelled. broker.conf里配置了brokerIP1和brokerIP2为这个broker所在的ip就行了,也不知道为啥 = = GitHub link: https://github.com/apache/rocketmq/discussions/7528#discussioncomment-8317020 This is an automatically sent

Re: [D] QuickStart Demo ERROR: Task was cancelled. [rocketmq]

2024-01-31 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: QuickStart Demo ERROR: Task was cancelled. 多网卡的时候,这里给客户端返回的ip可能选错了。无法联通,也会抱着个错误 GitHub link: https://github.com/apache/rocketmq/discussions/7528#discussioncomment-8317280 This is an automatically sent email for

Re: [D] QuickStart Demo ERROR: Task was cancelled. [rocketmq]

2024-01-31 Thread via GitHub
GitHub user leizhiyuan edited a comment on the discussion: QuickStart Demo ERROR: Task was cancelled. 1. 吧tls关掉看看 2. 可以提供一下服务端的日志。 3. sdk日志在~/logs/rocketmq/rocketmq-client.log,也可以发出来看看 GitHub link: https://github.com/apache/rocketmq/discussions/7528#discussioncomment-8316834 This is an

Re: [D] QuickStart Demo ERROR: Task was cancelled. [rocketmq]

2024-01-31 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: QuickStart Demo ERROR: Task was cancelled. 1. 吧tls关掉看看 2. 可以提供一下服务端的日志。 GitHub link: https://github.com/apache/rocketmq/discussions/7528#discussioncomment-8316834 This is an automatically sent email for dev@rocketmq.apache.org.

Re: [D] QuickStart Demo ERROR: Task was cancelled. [rocketmq]

2024-01-31 Thread via GitHub
GitHub user MmringZee added a comment to the discussion: QuickStart Demo ERROR: Task was cancelled. 我也遇到了这个问题,但我的情况是,和broker在同一个ip的项目可以正常运行,但是另一个机器ip上的项目就会报“Expected the service PushConsumerImpl-0 [FAILED] to be RUNNING, but the service has FAILED” 和 “Task was cancelled” GitHub link:

Re: [D] dledger集群模式(4.9版本)下,如何新添加一个节点到当前的集群中 [rocketmq]

2024-01-24 Thread via GitHub
GitHub user Songfeiyu1 closed a discussion: dledger集群模式(4.9版本)下,如何新添加一个节点到当前的集群中 dledger集群模式下,当前部署是3个节点,如何添加一个节点到当前的集群中,是配置好文件,启动这个broker,还是集群原有的3个节点也要修改配置文件,然后依次重启后,再启动新的broker呢? GitHub link: https://github.com/apache/rocketmq/discussions/7751 This is an automatically sent email for

Re: [I] Can not set custom MAX_HEAP_SIZE and HEAP_NEWSIZE [rocketmq-docker]

2023-11-15 Thread via GitHub
jsbxyyx commented on issue #94: URL: https://github.com/apache/rocketmq-docker/issues/94#issuecomment-1812286508 ``` broker setup copy an runbroker.sh,runserver.sh -v ./data/broker/bin/runbroker.sh:/home/rocketmq/rocketmq-${ROCKETMQ_VERSION}/bin/runbroker.sh -v

Re: [D] rocketmq 网络传输协议中magic code 是什么 [rocketmq]

2024-04-11 Thread via GitHub
GitHub user lizhanhui added a comment to the discussion: rocketmq 网络传输协议中magic code 是什么 He is looking for preface of a protocol. For example, SSL/TLS has a negotiation byte: https://tls12.xargs.org/#client-hello/annotated HTTP2 has connection preface:

Re: [I] need support arm64 [rocketmq-docker]

2024-04-11 Thread via GitHub
lizhanhui commented on issue #98: URL: https://github.com/apache/rocketmq-docker/issues/98#issuecomment-2050915389 Github Actions offers ARM64, can we set up a pipeline for this -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [D] 5.1.4 单机单节点启动Broker+Proxy无法发布消息? [rocketmq]

2024-04-11 Thread via GitHub
GitHub user jiahongzhen added a comment to the discussion: 5.1.4 单机单节点启动Broker+Proxy无法发布消息? I have the same problem, have you solved it? GitHub link: https://github.com/apache/rocketmq/discussions/7517#discussioncomment-9090466 This is an automatically sent email for

Re: [D] rocketmq 网络传输协议中magic code 是什么 [rocketmq]

2024-04-10 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: rocketmq 网络传输协议中magic code 是什么 用的是LengthFieldBasedFrameDecoder ,不存在magicCode 看看 encode的过程 org.apache.rocketmq.remoting.protocol.RemotingCommand#encode GitHub link:

Re: [D] rocketmq 网络传输协议中magic code 是什么 [rocketmq]

2024-04-10 Thread via GitHub
GitHub user dhsjgdf added a comment to the discussion: rocketmq 网络传输协议中magic code 是什么 这是来自QQ邮箱的假期自动回复邮件。   您好,我最近正在休假中,无法亲自回复您的邮件。我将在假期结束后,尽快给您回复。 GitHub link: https://github.com/apache/rocketmq/discussions/8014#discussioncomment-9077402 This is an automatically sent email for

Re: [I] need support arm64 [rocketmq-docker]

2024-04-10 Thread via GitHub
codefromthecrypt commented on issue #98: URL: https://github.com/apache/rocketmq-docker/issues/98#issuecomment-2048647866 I don't see any movement here. FYI, this is blocking integration with brave, as we need to test on arm64 as many devs laptops are using this. -- This is an automated

Re: [D] grpc拉取消息时返回空指针异常 [rocketmq]

2024-04-13 Thread via GitHub
GitHub user asjfoajs closed a discussion: grpc拉取消息时返回空指针异常 grpc拉取时返回CODE: INTERNAL_SERVER_ERROR, MESSAGE: null. NullPointerException. org.apache.rocketmq.proxy.grpc.v2.consumer.ReceiveMessageActivity.receiveMessage(ReceiveMessageActivity.java:66) 查看ReceiveMessageActivity.java:66代码 Settings

Re: [D] grpc拉取消息时返回空指针异常 [rocketmq]

2024-04-13 Thread via GitHub
GitHub user asjfoajs closed the discussion with a comment: grpc拉取消息时返回空指针异常 小白还想请教一下为啥这个地方会出错呢?看代码应该是获取客户端的信息吧? GitHub link: https://github.com/apache/rocketmq/discussions/8019#discussioncomment-9102653 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe,

Re: [D] grpc拉取消息时返回空指针异常 [rocketmq]

2024-04-13 Thread via GitHub
GitHub user asjfoajs reopened a discussion: grpc拉取消息时返回空指针异常 grpc拉取时返回CODE: INTERNAL_SERVER_ERROR, MESSAGE: null. NullPointerException. org.apache.rocketmq.proxy.grpc.v2.consumer.ReceiveMessageActivity.receiveMessage(ReceiveMessageActivity.java:66) 查看ReceiveMessageActivity.java:66代码 Settings

Re: [D] 发送消息报错No topic route info [rocketmq]

2024-04-16 Thread via GitHub
GitHub user leizhiyuan added a comment to the discussion: 发送消息报错No topic route info 看你截图,这个应该是消费者没启动,所以没有通过心跳生成retry topic,dashboard应该是依赖这个去取了一些信息,你可以手动把这个retry topic https://github.com/apache/rocketmq/assets/2684384/17559f3b-ea58-4a8d-bdf5-5adde76f8d32;> 创建一下,就可以了 GitHub link:

Re: [D] 发送消息报错No topic route info [rocketmq]

2024-04-15 Thread via GitHub
GitHub user cpupg added a comment to the discussion: 发送消息报错No topic route info namesrv在哪里配?监控台创建topic时没有相关表单,启动broker时已经给了namserv参数。 刚才试了下,监控台启动后日志里一直刷异常: ``` java.lang.NullPointerException: Cannot invoke "com.alibaba.fastjson.JSONObject.entrySet()" because "json" is null at

[PR] feat: allow disable controller component [rocketmq-docker]

2024-04-16 Thread via GitHub
liuweiGL opened a new pull request, #106: URL: https://github.com/apache/rocketmq-docker/pull/106 Local单副本模式部署并不需要开启 controller 组件,所以添加一个配置项进行控制是否需要发布 controller statefulset -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] feat: allow disable controller component [rocketmq-docker]

2024-04-16 Thread via GitHub
liuweiGL closed pull request #106: feat: allow disable controller component URL: https://github.com/apache/rocketmq-docker/pull/106 -- 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

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user lizhanhui added a comment to the discussion: 如何链接rocketmq静态库? 静态链接的话, 要确保依赖的版本和你项目中的依赖保持一致, 不然会有符号冲突; 目前还是推荐使用共享库, 共享库只暴露出来RocketMQ的符号, 第三方依赖的符号转为弱符号. https://www.gnu.org/software/gnulib/manual/html_node/Exported-Symbols-of-Shared-Libraries.html GitHub link:

Re: [D] centos7 编译rocketmq-5.0 cpp动态库方法 [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user lizhanhui added a comment to the discussion: centos7 编译rocketmq-5.0 cpp动态库方法 strip librocketmq.so后看看, 应该是符号表比较大. CMake的话记得加 -DCMAKE_BUILD_TYPE=Release Bazel的话, 加上 -c opt 参数 GitHub link: https://github.com/apache/rocketmq-clients/discussions/669#discussioncomment-9141808

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user lizhanhui added a comment to the discussion: 如何链接rocketmq静态库? 如果熟悉Bazel的话, 建议使用Bazel, 源码依赖, 使用类似Maven的dependency resolution 参考: https://maven.apache.org/guides/introduction/introduction-to-dependency-mechanism.html https://bazel.build/basics/dependencies GitHub link:

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: 如何链接rocketmq静态库? 5.x版本在编译的时候可以禁用protobuf吗 GitHub link: https://github.com/apache/rocketmq-clients/discussions/729#discussioncomment-9144172 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: 如何链接rocketmq静态库? 我的项目中已经使用了protobuf3.20, 编译rocketmq时, 使用的grpc是1.462 GitHub link: https://github.com/apache/rocketmq-clients/discussions/729#discussioncomment-9144340 This is an automatically sent email for dev@rocketmq.apache.org.

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库? 使用tag 5.0.1版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference , 找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题. 但是程序根本启动不了. 一启动就会出现如下错误.

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库? 使用5.0.1版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference , 找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题. 但是程序根本启动不了. 一启动就会出现如下错误.

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: 如何链接rocketmq静态库? 使用5.0版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference , 找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题. 但是程序根本启动不了. 一启动就会出现如下错误.

Re: [D] centos7 编译rocketmq-5.0 cpp动态库方法 [rocketmq-clients]

2024-04-17 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: centos7 编译rocketmq-5.0 cpp动态库方法 CMake 加上-DCMAKE_BUILD_TYPE=Release参数后, -rw-r--r-- 1 xxx algorithm 29M Apr 17 22:05 librocketmq.a -rwxr-xr-x 1 xxx algorithm 52M Apr 17 22:05 librocketmq.so 小了不少 GitHub link:

Re: [D] 发送消息报错No topic route info [rocketmq]

2024-04-16 Thread via GitHub
GitHub user cpupg added a comment to the discussion: 发送消息报错No topic route info 破了一半。`MessageListener#consume`改好后可以消费了,但是日志里还是报错no topic route

Re: [D] centos7 编译rocketmq-5.0 cpp动态库方法 [rocketmq-clients]

2024-04-16 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: centos7 编译rocketmq-5.0 cpp动态库方法 我编译出来的动态库和静态库的大小 -rw-r--r-- 1 xxx algorithm 200M Apr 16 22:11 librocketmq.a -rwxr-xr-x 1 xxx algorithm 61M Apr 16 22:11 librocketmq.so 请问一下: librocketmq.a依赖的静态库都是已经打进了librocketmq.a里面了吧, 工程中如果使用的话,

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-16 Thread via GitHub
GitHub user cgeffect edited a discussion: 如何链接rocketmq静态库? 系统: linux centos 版本: 5.0.1 -rw-r--r-- 1 xxx algorithm 200M Apr 16 22:11 librocketmq.a -rwxr-xr-x 1 xxx algorithm 61M Apr 16 22:11 librocketmq.so 已经编译出了librocketmq.a, 还有libproto.a和libopencensus_proto.a, 工程链接只链接librocketmq.a不行,

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-16 Thread via GitHub
GitHub user cgeffect edited a discussion: 如何链接rocketmq静态库? 系统: linux centos 版本: 5.0.1 -rw-r--r-- 1 xxx algorithm 200M Apr 16 22:11 librocketmq.a -rwxr-xr-x 1 xxx algorithm 61M Apr 16 22:11 librocketmq.so 已经编译出了librocketmq.a, 还有libproto.a和libopencensus_proto.a, 工程链接只链接librocketmq.a不行,

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-16 Thread via GitHub
GitHub user cgeffect edited a discussion: 如何链接rocketmq静态库? 系统: linux centos 版本: 5.0.1 -rw-r--r-- 1 xxx algorithm 200M Apr 16 22:11 librocketmq.a -rwxr-xr-x 1 xxx algorithm 61M Apr 16 22:11 librocketmq.so 已经编译出了librocketmq.a, 还有libproto.a和libopencensus_proto.a, 工程链接只链接librocketmq.a不行,

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-18 Thread via GitHub
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库? 我的项目中已经使用了protobuf3.20, 编译rocketmq时, 使用的grpc是1.462, grpc内部使用的protobuf是3.19.0, 目前确认时因为两个protobuf版本不同, 导致的crash. 有什么办法可把rocketmq里的依赖的静态库完全和工程里的静态库符号完全隔离? 通过这种方式吗?

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-18 Thread via GitHub
GitHub user cgeffect deleted a comment on the discussion: 如何链接rocketmq静态库? 5.x版本在编译的时候可以禁用protobuf吗 GitHub link: https://github.com/apache/rocketmq-clients/discussions/729#discussioncomment-9144172 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please

Re: [I] 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言 [rocketmq-client-nodejs]

2024-04-22 Thread via GitHub
JanYork commented on issue #25: URL: https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-2068925805 功能是齐全的吗? -- 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

Re: [D] c++ rocketmq::Producer析构时程序crash [rocketmq-clients]

2024-04-22 Thread via GitHub
GitHub user cgeffect edited a discussion: c++ rocketmq::Producer析构时程序crash 在一个函数内部创建了一个rocketmq::Producer, 注册的topic还没有在控制台创建, 出了函数作用域rocketmq::Producer析构. 程序crash [2024-04-22 18:41:01.045] [info] [ClientImpl.cpp:304] Create inflight route query cache for topic=algorithm_topic [2024-04-22

Re: [D] 如何链接rocketmq静态库? [rocketmq-clients]

2024-04-22 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: 如何链接rocketmq静态库? 已解决 GitHub link: https://github.com/apache/rocketmq-clients/discussions/729#discussioncomment-9190113 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to:

Re: [D] rocketmq::Producer析构时程序crash [rocketmq-clients]

2024-04-22 Thread via GitHub
GitHub user cgeffect added a comment to the discussion: rocketmq::Producer析构时程序crash 又确认了一遍, 和topic是否提前在控制台注册与否没关系, 是rocketmq::Producer析构导致的crash GitHub link: https://github.com/apache/rocketmq-clients/discussions/733#discussioncomment-9189987 This is an automatically sent email for

Re: [D] c++ rocketmq::Producer析构时程序crash [rocketmq-clients]

2024-04-22 Thread via GitHub
GitHub user cgeffect edited a discussion: c++ rocketmq::Producer析构时程序crash Linux centos, rocketmq 5.0.1版本 在一个函数内部创建了一个rocketmq::Producer, 注册的topic还没有在控制台创建, 出了函数作用域rocketmq::Producer析构. 程序crash [2024-04-22 18:41:01.045] [info] [ClientImpl.cpp:304] Create inflight route query cache for

Re: [D] [crash bug] c++ rocketmq::Producer析构时程序crash [rocketmq-clients]

2024-04-22 Thread via GitHub
GitHub user cgeffect edited a discussion: [crash bug] c++ rocketmq::Producer析构时程序crash Linux centos, rocketmq 5.0.1版本 在一个函数内部创建了一个rocketmq::Producer, 注册的topic还没有在控制台创建, 出了函数作用域rocketmq::Producer析构. 程序crash [2024-04-22 18:41:01.045] [info] [ClientImpl.cpp:304] Create inflight route query

Re: [I] 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言 [rocketmq-client-nodejs]

2024-04-23 Thread via GitHub
wuteng606 commented on issue #25: URL: https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-2071560253 是和[rocketmq-client-nodejs](https://github.com/apache/rocketmq-client-nodejs)功能一样的,只是升级了下版本兼容问题,如果可以,你可以直接看源码了解下 -- This is an automated message from the Apache Git

Re: [D] 发送消息报错No topic route info [rocketmq]

2024-04-14 Thread via GitHub
GitHub user biningo added a comment to the discussion: 发送消息报错No topic route info 可以确认下rocketmq dashboard配置的namesrv地址是不是对的,dashboard有报错日志吗?一般遇到这种【No topic route info】就是namesrv地址没配对或者topic根本没创建 GitHub link: https://github.com/apache/rocketmq/discussions/8008#discussioncomment-9107785

Re: [I] rocketmq 5.1.3部署问题 [rocketmq-docker]

2024-04-14 Thread via GitHub
huangsunting commented on issue #95: URL: https://github.com/apache/rocketmq-docker/issues/95#issuecomment-2054001738 官方文档比较坑,甚至没有docker的部署示例。。。 rocketmq5.x引入了proxy,需要开放一下端口,不然访问不了。 # 1.先简单安装一下,8081是grpc访问端口,8080是remoting访问(如果需要) docker run -d \ --name rmqbroker \ --net

Re: [I] 求助 单机通过docker-compose部署5.1.3 [rocketmq-docker]

2024-04-14 Thread via GitHub
huangsunting commented on issue #88: URL: https://github.com/apache/rocketmq-docker/issues/88#issuecomment-2054002070 官方文档比较坑,甚至没有docker的部署示例。。。 rocketmq5.x引入了proxy,需要开放一下端口,不然访问不了。 1.先简单安装一下,8081是grpc访问端口,8080是remoting访问(如果需要) docker run -d --name rmqbroker --net rmq_net

<    2   3   4   5   6   7   8   9   >