Re: [D] RocketMQ 在broker 重启时, 生产者显示消息发送超时,但该消息仍被mq接收 [rocketmq]

2024-08-29 Thread via GitHub
GitHub user pxd98 closed a discussion: RocketMQ 在broker 重启时, 生产者显示消息发送超时,但该消息仍被mq接收 RocketMQ版本为4.9.1,生产者是同步发送,broker端为同步双写。在重启一个Broker主节点的时候发现在该节点刚重启完的时候出现了超时(sendDefaultImpl call timeout),生产者的超时时间设置为3s,使用mqadmin 查询该消息显示该消息已被成功投递。怀疑是刚重启完成后生产者准备往这个节点发送消息,但发送失败,此时已经判断与该节点无法连接的用时已经超过了3s,导致直接发送超时

Re: [D] RocketMQ fastListenPort设置问题 [rocketmq]

2024-08-29 Thread via GitHub
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

Re: [D] rocketmq SDK的使用 [rocketmq]

2024-08-29 Thread via GitHub
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

Re: [D] Rocketmq5 中的namespace功能能否使用 [rocketmq]

2024-08-29 Thread via GitHub
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.

Re: [D] [RocketMQ 5.1.4] 内外网隔离的情况下,怎么做到内外网都可以通过MQ收发消息 [rocketmq]

2024-08-29 Thread via GitHub
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

Re: [D] [RocketMQ 5.1.4] 内外网隔离的情况下,怎么做到内外网都可以通过MQ收发消息 [rocketmq]

2024-08-29 Thread via GitHub
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

Re: [I] Use rocketmq-client-java 5.0.6 CancellationException: Task was cancelled (UNIMPLEMENTED: HTTP status code 404) [rocketmq-docker]

2024-08-29 Thread via GitHub
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

Re: [D] rocketmq5 proxy 的兼容性问题 [rocketmq]

2024-08-29 Thread via GitHub
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