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
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
GitHub user cserwen added a comment to the discussion:
集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况?
RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的
- Rebalance 是最终一致,各个 consumer 会定时查询 Topic 分区信息和 订阅组消费者信息,来计算自己应该消费的队列
- 除了你提到的这些情况,还可能多个 consumer 的 clientID 一样,然后计算出相同的分区,也会重复,由于 push
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:
GitHub user cserwen edited a comment on the discussion:
集群消费模式下,是否在某些情况下,存在同一个队列被 同一个消费组的 多个消费者消费的情况?
RocketMQ 支持 at-least-once 语义,至少投递一次,不保证只消费一次,然后上述情况是会出现的
- Rebalance 是最终一致,除了服务端主动通知,各个 consumer 会定时查询 Topic 分区信息和消费者信息,来计算自己应该消费的队列
- 除了你提到的这些情况,还可能多个 consumer 的 clientID
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
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
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:
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
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
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
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
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.
..
***@***.***
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
GitHub user MmringZee added a comment to the discussion: JVM parameter
configuration failure
但是虚拟内存也意味着rocketmq需要申请到那么多资源才能启动,即使不需要真实地使用。
我现在的场景就是需要在k8s里部署rocketmq,但是因为这个情况我发现我不得不把request设置得很大,这会占用掉很多的集群资源 T.T
GitHub link:
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。后面在开发环境才发现内存占用量很高这个事情。
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
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
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:
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
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
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:
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发送消息
*
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
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:
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
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)
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
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
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:
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:
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
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
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,
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
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
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
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
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
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
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
GitHub user Conmi-WhiteJoker edited a comment on the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
是的,我想controller作为生产者提交数据到rocketmq,同时能实时响应消费者处理完成后的返回数据。或者设置一个超时时间,超过了就跳过监听返回数据
GitHub link:
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
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
GitHub user Conmi-WhiteJoker added a comment to the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
> 你这个场景没必要使用消息,而且生产者也并不知道消费者消费完,因为有可能有多个消费组。吧消息的解耦又想变成耦合。没有实际意义感觉。
GitHub user leizhiyuan added a comment to the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
你这种不如吧controller改造成一个异步接口,进来发完消息,就返回accept,然后你下游处理完成后,再回调上游的一个接口来更新结果。
如果不行,就是 @cserwen 说的,参考 https://www.cnblogs.com/yunqishequ/p/12511391.html
这个看看这种用法,
GitHub user Conmi-WhiteJoker added a comment to the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
> 你这种不如吧controller改造成一个异步接口,进来发完消息,就返回accept,然后你下游处理完成后,再回调上游的一个接口来更新结果。
>
> 如果不行,就是 @cserwen 说的,参考 https://www.cnblogs.com/yunqishequ/p/12511391.html
> 这个看看这种用法,
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
GitHub user Conmi-WhiteJoker added a comment to the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
GitHub user Conmi-WhiteJoker deleted a comment on the discussion:
如果我想在controller中调用rocketmq发送消息,并等待消息处理完成后返回再执行下一步,有没有这个方法?
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:
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
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
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
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
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
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
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.
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:
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
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
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:
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
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
GitHub user leizhiyuan added a comment to the discussion: rocketmq 网络传输协议中magic
code 是什么
用的是LengthFieldBasedFrameDecoder ,不存在magicCode
看看 encode的过程 org.apache.rocketmq.remoting.protocol.RemotingCommand#encode
GitHub link:
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
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
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
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,
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
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:
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
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
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
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:
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
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:
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
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.
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库?
使用tag 5.0.1版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference ,
找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题.
但是程序根本启动不了. 一启动就会出现如下错误.
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库?
使用5.0.1版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference ,
找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题.
但是程序根本启动不了. 一启动就会出现如下错误.
GitHub user cgeffect added a comment to the discussion: 如何链接rocketmq静态库?
使用5.0版本, 使用cmake和bazel都编译出了静态库, 在工程中链接时会出现undefine reference ,
找不到rocketmq里的实现. 感觉cmake写的没有问题. 又把工程中链接的库改为动态库librocketmq.so, 链接没问题.
但是程序根本启动不了. 一启动就会出现如下错误.
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:
GitHub user cpupg added a comment to the discussion: 发送消息报错No topic route info
破了一半。`MessageListener#consume`改好后可以消费了,但是日志里还是报错no topic route
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里面了吧, 工程中如果使用的话,
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不行,
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不行,
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不行,
GitHub user cgeffect edited a comment on the discussion: 如何链接rocketmq静态库?
我的项目中已经使用了protobuf3.20, 编译rocketmq时, 使用的grpc是1.462, grpc内部使用的protobuf是3.19.0,
目前确认时因为两个protobuf版本不同, 导致的crash. 有什么办法可把rocketmq里的依赖的静态库完全和工程里的静态库符号完全隔离?
通过这种方式吗?
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
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
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
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:
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
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
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
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
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
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
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
601 - 700 of 876 matches
Mail list logo