GitHub user pxd98 closed a discussion: RocketMQ 在broker 重启时,
生产者显示消息发送超时,但该消息仍被mq接收
RocketMQ版本为4.9.1,生产者是同步发送,broker端为同步双写。在重启一个Broker主节点的时候发现在该节点刚重启完的时候出现了超时(sendDefaultImpl
call timeout),生产者的超时时间设置为3s,使用mqadmin
查询该消息显示该消息已被成功投递。怀疑是刚重启完成后生产者准备往这个节点发送消息,但发送失败,此时已经判断与该节点无法连接的用时已经超过了3s,导致直接发送超时
GitHub user pxd98 closed a discussion: RocketMQ fastListenPort设置问题
RocketMQ
4.9.1的版本中是不是在broker.conf中设置了fastListenPort并没有用?就是10909这个vip端口,我看好像初始化时直接设为listenPort-2了,在代码里没找到将设置读入的地方。
GitHub link: https://github.com/apache/rocketmq/discussions/7158
This is an automatically sent email for de
GitHub user pxd98 added a comment to the discussion: rocketmq SDK的使用
这里应该是要配broker的地址,不是nameserver的地址,还有就是remotingClient要先start
GitHub link:
https://github.com/apache/rocketmq/discussions/7918#discussioncomment-10485254
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user pxd98 closed a discussion: Rocketmq5 中的namespace功能能否使用
我看到rocketmq5中可以在request的extfield中增加namespace
filed了,这个是不是说明rocketmq已经支持了namespace了,但是我看文档中还没有涉及
GitHub link: https://github.com/apache/rocketmq/discussions/8010
This is an automatically sent email for dev@rocketmq.apache.
GitHub user pxd98 added a comment to the discussion: [RocketMQ 5.1.4]
内外网隔离的情况下,怎么做到内外网都可以通过MQ收发消息
能否把brokerIP设置为域名,然后加hosts或者dns解析来解决?
GitHub link:
https://github.com/apache/rocketmq/discussions/7558#discussioncomment-10485293
This is an automatically sent email for dev@rocketmq.apache
GitHub user pxd98 added a comment to the discussion: [RocketMQ 5.1.4]
内外网隔离的情况下,怎么做到内外网都可以通过MQ收发消息
proxy应该也是一样,把自己的brokerIP写到topic
route里发给客户端,可以试一下proxy里的IP配外网IP,外网客户端连proxy。内网客户端连nameserver,不连proxy
GitHub link:
https://github.com/apache/rocketmq/discussions/7558#discussioncomment-10492906
isMrZhang closed issue #110: Use rocketmq-client-java 5.0.6
CancellationException: Task was cancelled (UNIMPLEMENTED: HTTP status code 404)
URL: https://github.com/apache/rocketmq-docker/issues/110
--
This is an automated message from the Apache Git Service.
To respond to the message, please
GitHub user PHK-20 closed the discussion with a comment: rocketmq5 proxy 的兼容性问题
用的是github.com/apache/rocketmq-client-go/v2 如何解决这个问题呢
GitHub link:
https://github.com/apache/rocketmq/discussions/7919#discussioncomment-10493501
This is an automatically sent email for dev@rocketmq.apache.org