[GitHub] [rocketmq] xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？
GitHub user xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？ 您好，首先感谢您的回复。 按照你说的，就是目前的4.x版本中。就算不做任何修改。broker部署的时候，填写每一个namesrv的ip。而生产者和客户端，就目前，也是可以使用lb负载到每一个namesrv的，对吧。 如果按照这个逻辑，也就是broker注册的时候，他会每次遍历所有的namesrv注册，对吧。 --- 我们从rocketmq的dashboard中，能够看到消费者的节点ip，如果是这个逻辑，我理解消费者并不是只读操作，也要写。 如果消费者通过lb把自己的ip上报给namesrv1，那么namesrv2和3没得上报信息，这个时候dashboard可能是看不到消费者 GitHub link: https://github.com/apache/rocketmq/discussions/7286#discussioncomment-6900050 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xhrg added a comment to the discussion: namesrv前面是否可以绑定LB？？？
GitHub user xhrg added a comment to the discussion: namesrv前面是否可以绑定LB？？？ 您好，首先感谢您的回复。 按照你说的，就是目前的4.x版本中。就算不做任何修改。broker部署的时候，填写每一个namesrv的ip。而生产者和客户端，就目前，也是使用lb。按照这个逻辑，也就是broker注册的时候，他会遍历所有的namesrv注册，对吧。 GitHub link: https://github.com/apache/rocketmq/discussions/7286#discussioncomment-6900050 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？
GitHub user xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？ 您好，首先感谢您的回复。 按照你说的，就是目前的4.x版本中。就算不做任何修改。broker部署的时候，填写每一个namesrv的ip。而生产者和客户端，就目前，也是可以使用lb负载到每一个namesrv的，对吧。 如果按照这个逻辑，也就是broker注册的时候，他会每次遍历所有的namesrv注册，对吧。 GitHub link: https://github.com/apache/rocketmq/discussions/7286#discussioncomment-6900050 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？
GitHub user xhrg edited a comment on the discussion: namesrv前面是否可以绑定LB？？？ 您好，感谢您的回复。 按照你说的，就是目前的4.x版本中。就算不做任何修改。broker部署的时候，填写每一个namesrv的ip。而生产者和客户端，就目前，也是可以使用lb负载到每一个namesrv的，对吧。 如果按照这个逻辑，也就是broker注册的时候，他会每次遍历所有的namesrv注册，对吧。 --- 我们从rocketmq的dashboard中，能够看到消费者的节点ip，如果是这个逻辑，我理解消费者并不是只读操作，也要写。 如果消费者通过lb把自己的ip上报给namesrv1，那么namesrv2和3没得上报信息，这个时候dashboard可能是看不到消费者 GitHub link: https://github.com/apache/rocketmq/discussions/7286#discussioncomment-6900050 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-docker] CyJaySong commented on issue #88: 求助 单机通过docker-compose部署5.1.3
CyJaySong commented on issue #88: URL: https://github.com/apache/rocketmq-docker/issues/88#issuecomment-1703829648 > set broker dir permission @CyJaySong > > [this issues ](https://github.com/foxiswho/docker-rocketmq/issues/28) broker 正常启动了的只是，客户端无法链接 -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl 在broker_default.log中打印的这个错误，jps有namesrv和proxy GitHub link: https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6902498 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl 换了java8也报这个错 GitHub link: https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6902471 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl 在broker_default.log中打印的这个错误，jps有namesrv和proxy GitHub link: https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6902494 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-docker] RongtongJin opened a new pull request, #91: Remove wrong config to pass CI
RongtongJin opened a new pull request, #91: URL: https://github.com/apache/rocketmq-docker/pull/91 Remove wrong config to pass CI -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq-docker] xdkxlk merged pull request #91: Remove wrong config to pass CI
xdkxlk merged PR #91: URL: https://github.com/apache/rocketmq-docker/pull/91 -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] mxsm added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy
GitHub user mxsm added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy @alloyinfo能贴出日志中的错误日志堆栈的信息吗？ GitHub link: https://github.com/apache/rocketmq/discussions/7291#discussioncomment-6910372 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] ShadowySpirits added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user ShadowySpirits added a comment to the discussion: 请教使用 rust client 连接失败的问题 ``` ...create session success, peer: 172.16.0.182:9876... ``` 从你的报错来看是尝试直接连接 nameserver，需要改成 Proxy 的地址 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932732 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题 多谢多谢，我单独建一个proxy服务试试看 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6933388 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: java版本的客户端jar包都没有上传maven中央仓库是吗
GitHub user francisoliverlee added a comment to the discussion: java版本的客户端jar包都没有上传maven中央仓库是吗 https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client-java;>here GitHub link: https://github.com/apache/rocketmq-clients/discussions/568#discussioncomment-6932283 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题 开始我也判断是问题了问题，后来把代码放在跟 RocketMQ Dashboard 服务同一个机器上测试。 Dashboard 能连接成功，但代码还是报这个错误。 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932717 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq edited a comment on the discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq edited a comment on the discussion: 请教使用 rust client 连接失败的问题 开始我也判断是网络问题，后来把代码放在跟 RocketMQ Dashboard 服务同一个机器上测试。 Dashboard 能连接成功，但代码还是报这个错误。 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932717 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: Rocket5.0.5 Java客户端如何设置广播消费
GitHub user francisoliverlee added a comment to the discussion: Rocket5.0.5 Java客户端如何设置广播消费 you are right , check the comment https://github.com/apache/rocketmq-clients/blob/973c9580d4ed1b4cf31f9f7df1b290d22b50c6a0/java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/PushConsumer.java#L47C1-L56;>here GitHub link: https://github.com/apache/rocketmq-clients/discussions/572#discussioncomment-6932270 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: Subscribe some topics by topic pattern
GitHub user onejimmyboy added a comment to the discussion: Subscribe some topics by topic pattern 可以尝试发送消息的时候增加tags，消费者消费的时候对tags进行过滤，这样消费者就可以选择性的消费消息。应该能满足你的需求 GitHub link: https://github.com/apache/rocketmq/discussions/7297#discussioncomment-6932072 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] lizhanhui added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user lizhanhui added a comment to the discussion: 请教使用 rust client 连接失败的问题 看报错，是网络联通性问题。建议用telnet或者其它网络工具验证下。 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932706 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: create grpc conn failed, err=context deadline exceeded
GitHub user francisoliverlee added a comment to the discussion: create grpc conn failed, err=context deadline exceeded check network ok or not. 1. ping proxyip 2. telnet proxyip:proxyport GitHub link: https://github.com/apache/rocketmq-clients/discussions/579#discussioncomment-6932244 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq edited a discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq edited a discussion: 请教使用 rust client 连接失败的问题
同一个机器上安装的 RocketMQ Dashboard 可正常连接管理。但使用的是官方
https://github.com/apache/rocketmq-clients/blob/master/rust/examples/producer.rs
的例子一直提示如下错误：
```
Compiling testmq v0.1.0 (/root/testmq)
Finished dev [unoptimized + debuginfo] target(s) in 5.50s
Running `target/debug/testmq`
Sep 07 03:06:15.214
INFO[/root/.cargo/registry/src/index.crates.io-6f17d22bba15001f/rocketmq-5.0.0/src/session.rs:175:9]
create session success, peer: 172.16.0.182:9876, component: session
producer start failed: Client internal error at client.start => send rpc
telemetry failed
Context:
called: session.start
Source: status: Unknown, message: "transport error", details: [], metadata:
MetadataMap { headers: {} }
Caused by:
0: transport error
1: connection error: stream closed because of a broken pipe
2: stream closed because of a broken pipe
```
2个服务的启动方式：
```
sh mqnamesrv
sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/conf/broker.conf --enable-proxy
```
broker.conf 配置如下
```
# 集群名称
brokerClusterName = DefaultCluster
# 节点名称
brokerName = broker-a
# broker id节点ID， 0 表示 master, 其他的正整数表示 slave，不能小于0
brokerId = 0
# Broker服务地址String 内部使用填内网ip，如果是需要给外部使用填公网ip
brokerIP1 = 172.16.0.182
# Broker角色
brokerRole = ASYNC_MASTER
# 刷盘方式
flushDiskType = ASYNC_FLUSH
# 在每天的什么时间删除已经超过文件保留时间的 commit log，默认值04
deleteWhen = 04
# 以小时计算的文件保留时间 默认值72小时
fileReservedTime = 72
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许Broker自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
```
请问可能是什么问题？谢谢
GitHub link: https://github.com/apache/rocketmq-clients/discussions/597
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: PushConsumerImpl -> PushSubscriptionSettings 类的 fifo 和 retryPolicy 默认值问题
GitHub user francisoliverlee added a comment to the discussion: PushConsumerImpl -> PushSubscriptionSettings 类的 fifo 和 retryPolicy 默认值问题 真正的retryPolicy是把proxy的retry默认配置和客户端上报上来做了merge后产生的。客户端启动后把client setting上报到proxy，proxy就会把自己的配置和上报上来的client setting合并为一份client setting，然后客户端拉取同步。 具体可以参考代码：ClientActivity.telemetry() fifo是消费者配置为顺序消费的时候，就是fifo. 在创建消费者组的时候可以指定。 代码可以参考：updateAndCreateSubscriptionGroup GitHub link: https://github.com/apache/rocketmq-clients/discussions/537#discussioncomment-6932478 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq added a comment to the discussion: 请教使用 rust client 连接失败的问题 sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/conf/broker.conf --enable-proxy ，我理解使用 --enable-proxy 参数是开启了 proxy ， 这样对吗？ GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932730 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] doveq edited a comment on the discussion: 请教使用 rust client 连接失败的问题
GitHub user doveq edited a comment on the discussion: 请教使用 rust client 连接失败的问题 开始我也判断是网络问题，后来把代码放在跟 RocketMQ Dashboard 服务同一个docker容器里。 Dashboard 能连接成功，但代码还是报这个错误。 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932717 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] ShadowySpirits added a comment to the discussion: 请教使用 rust client 连接失败的问题
GitHub user ShadowySpirits added a comment to the discussion: 请教使用 rust client 连接失败的问题 Rust client 适用于 Proxy 架构的 RocketMQ，请确认下是否正确启动了 Proxy GitHub link: https://github.com/apache/rocketmq-clients/discussions/597#discussioncomment-6932722 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] francisoliverlee added a comment to the discussion: 如要我要实现一个基于RocketMQ4.X版本或者5.X版本的client，去哪里获取资料？
GitHub user francisoliverlee added a comment to the discussion: 如要我要实现一个基于RocketMQ4.X版本或者5.X版本的client，去哪里获取资料？ > 如要我要实现一个基于RocketMQ4.X版本或者5.X版本的client，没有找到相应的规范说明，如果的有的的话能否给出链接？如果没有的话，是否有参考文档？ 是nodejs嘛？ GitHub link: https://github.com/apache/rocketmq-clients/discussions/534#discussioncomment-6932482 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] joeCarf added a comment to the discussion: 5.x开启controller模式broker启动失败，NullPointerException
GitHub user joeCarf added a comment to the discussion: 5.x开启controller模式broker启动失败，NullPointerException 麻烦贴一下详细的报错栈，感谢～ GitHub link: https://github.com/apache/rocketmq/discussions/7333#discussioncomment-6963179 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] Dengsi added a comment to the discussion: Subscribe some topics by topic pattern
GitHub user Dengsi added a comment to the discussion: Subscribe some topics by topic pattern 感谢回复，但我这边的需求是启动一个Consumer，同时监听名称以proxy结尾的所有topic GitHub link: https://github.com/apache/rocketmq/discussions/7297#discussioncomment-6934764 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy edited a discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？
GitHub user onejimmyboy edited a discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？ 1：版本 RocketMQ5.1.3 2：jdk1.8 3：集群形态：DLedger Controller 模式 集群1：嵌入namesrv，3个节点（1个controller，2个broker+controller），1主1从 集群2：嵌入namesrv，5个节点（1个controller，2个broker+controller，2个broker），2主1从 4：现象 在使用./producer.sh测试生成tps时，发现1主1从的tps要明显高于2主1从的tps，那按照这种现象，如果多个主的话tps会很低的，岂不是性能很低。面对大数据量的情况下，是不是扩节点就会影响tps性能了？   GitHub link: https://github.com/apache/rocketmq/discussions/7357 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] joeCarf added a comment to the discussion: Prepare to release Apache RocketMQ 5.1.4
GitHub user joeCarf added a comment to the discussion: Prepare to release Apache RocketMQ 5.1.4 +1 GitHub link: https://github.com/apache/rocketmq/discussions/7360#discussioncomment-7020260 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] joeCarf added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null
GitHub user joeCarf added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null hi 贴一下你的指令 我看下能否复现 GitHub link: https://github.com/apache/rocketmq/discussions/7245#discussioncomment-6812510 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-client-python] huangwjwork opened a new issue, #142: what the max msg body size consumer supported
huangwjwork opened a new issue, #142: URL: https://github.com/apache/rocketmq-client-python/issues/142 when I consumer some msg ，I got exception ``` terminate called after throwing an instance of "boost::exception_detail::clone_ipml>" what(): zlib error ``` the original msg more than 7000 byte , After I delete some fields, msg size only 4000byte , and I solve this exception my enviorment os：rhel7.9 python： 3.9.16 rocket-client-cpp-2.0.0-centos.x86_64 rocketmq-client-python 2.0.0 -- 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: dev-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is nu
GitHub user RongtongJin added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null > mq版本：rocketmq-all-5.1.3-bin-release.zip 系统centos7 启动Broker报 > java.lang.NullPointerException: Cannot invoke > "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" > because "this.timerFlushService" is null at > org.apache.rocketmq.store.timer.TimerMessageStore.shutdown(TimerMessageStore.java:511) > at > org.apache.rocketmq.broker.BrokerController.shutdownBasicService(BrokerController.java:1338) > at > org.apache.rocketmq.broker.BrokerController.shutdown(BrokerController.java:1464) > at > org.apache.rocketmq.broker.BrokerStartup.createBrokerController(BrokerStartup.java:242) > at org.apache.rocketmq.broker.BrokerStartup.main(BrokerStartup.java:50) > 请问如何处理 这个应该不是broker启动不了的原因。标准输出有打印什么错误信息吗 GitHub link: https://github.com/apache/rocketmq/discussions/7245#discussioncomment-6880598 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: namesrv前面是否可以绑定LB？？？
GitHub user RongtongJin added a comment to the discussion: namesrv前面是否可以绑定LB？？？ > 如果我使用一个LB负载均衡器，转发到3个namesrv节点。这样肯定是有问题的。因为可能注册broker到namesrv-1节点，而读的时候，lb又可能把请求转发到namesrv-2节点。 > > 如果我对namserv进行改造，实现彼此之间同步数据，那这样是否可以使用LB负载到三个节点。这样我在写namesrv的时候，可以使用域名的方式。 > > 集群切换的时候会方便一些。 对于客户端来说，可以用LB，对于broker来说，要向每一个nameserver注册，所以要获得全量的nameserver地址，否则路由信息将会不一致。 暂时不会考虑namesrv之间同步数据。 GitHub link: https://github.com/apache/rocketmq/discussions/7286#discussioncomment-6880580 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo closed a discussion: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user alloyinfo closed a discussion: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl GitHub link: https://github.com/apache/rocketmq/discussions/7274 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] Wjkcc closed a discussion: 5.13 m1 broker 启动报错
GitHub user Wjkcc closed a discussion: 5.13 m1 broker 启动报错 启动命令 sudo nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf --enable-proxy & 报错信息 java.lang.UnsatisfiedLinkError: /private/var/folders/92/f4v8q4tj42b_x0l1lzrvv2qhgn/T/jna--1193728071/jna8909410615761299778.tmp: dlopen(/private/var/folders/92/f4v8q4tj42b_x0l1lzrvv2qhgn/T/jna--1193728071/jna8909410615761299778.tmp, 0x0001): tried: '/private/var/folders/92/f4v8q4tj42b_x0l1lzrvv2qhgn/T/jna--1193728071/jna8909410615761299778.tmp' (fat file, but missing compatible architecture (have 'i386,x86_64', need 'arm64e')), '/usr/local/lib/jna8909410615761299778.tmp' (no such file), '/usr/lib/jna8909410615761299778.tmp' (no such file) at java.lang.ClassLoader$NativeLibrary.load(Native Method) at java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1950) at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1832) at java.lang.Runtime.load0(Runtime.java:811) at java.lang.System.load(System.java:1088) at com.sun.jna.Native.loadNativeDispatchLibraryFromClasspath(Native.java:851) at com.sun.jna.Native.loadNativeDispatchLibrary(Native.java:826) at com.sun.jna.Native.(Native.java:140) at org.apache.rocketmq.store.util.LibC.(LibC.java:26) at org.apache.rocketmq.store.CommitLog$ColdDataCheckService.initPageSize(CommitLog.java:2188) at org.apache.rocketmq.store.CommitLog$ColdDataCheckService.(CommitLog.java:2071) at org.apache.rocketmq.store.CommitLog.(CommitLog.java:112) at org.apache.rocketmq.store.DefaultMessageStore.(DefaultMessageStore.java:221) at org.apache.rocketmq.broker.BrokerController.initializeMessageStore(BrokerController.java:749) at org.apache.rocketmq.broker.BrokerController.initialize(BrokerController.java:786) at org.apache.rocketmq.broker.BrokerStartup.createBrokerController(BrokerStartup.java:240) at org.apache.rocketmq.proxy.ProxyStartup.createBrokerController(ProxyStartup.java:216) at org.apache.rocketmq.proxy.ProxyStartup.createMessagingProcessor(ProxyStartup.java:174) at org.apache.rocketmq.proxy.ProxyStartup.main(ProxyStartup.java:76) GitHub link: https://github.com/apache/rocketmq/discussions/7288 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] ddfnddfn2 closed a discussion: request-reply特性(rpc)，客户端支持其他语言吗
GitHub user ddfnddfn2 closed a discussion: request-reply特性(rpc)，客户端支持其他语言吗 没有找到其他语言的案例，客户端支持C#、C++吗 GitHub link: https://github.com/apache/rocketmq/discussions/7278 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin closed the discussion with a comment: request-reply特性(rpc)，客户端支持其他语言吗
GitHub user RongtongJin closed the discussion with a comment: request-reply特性(rpc)，客户端支持其他语言吗 > 没有找到其他语言的案例，客户端支持C#、C++吗 暂时不支持。 GitHub link: https://github.com/apache/rocketmq/discussions/7278#discussioncomment-6880593 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: 5.13 m1 broker 启动报错
GitHub user RongtongJin added a comment to the discussion: 5.13 m1 broker 启动报错 #7014 已经修复，等下个版本就好。 GitHub link: https://github.com/apache/rocketmq/discussions/7288#discussioncomment-6880589 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] mxsm added a comment to the discussion: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user mxsm added a comment to the discussion: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl > java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set > into : sun.nio.ch.EPollSelectorImpl 现在Rocketmq的版本还是在Jdk8, JDK9+会出现一些问题。使用建议还是在JDK8进行使用， 社区应该也在做相关的JDK升级的工作。 GitHub link: https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6843566 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] mxsm edited a comment on the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null
GitHub user mxsm edited a comment on the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null @RongtongJin @yidazhi 可以看一下这个 ISSUE #7269 . 导致的原因是可能配置的问题导致Broker的某些启动错误，具体是哪个配置的问题你可以贴出来你的配置或者自己对照官网排查一下。 然后触发退出的操作。在退出过程中 TimerMessageStore 的属性并没有实例化，在执行shutdown的时候空指针了。 @RongtongJin 麻烦review pr #7270 代码 GitHub link: https://github.com/apache/rocketmq/discussions/7245#discussioncomment-6887196 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-clients] eventhorizon-cli edited a discussion: csharp: replace nlog with Microsoft.Extensions.Logging
GitHub user eventhorizon-cli edited a discussion: csharp: replace nlog with
Microsoft.Extensions.Logging
The logs of csharp client are written to files by default, and cannot be
written only to the console, this is not very friendly to the .net developers.
1. This kind of logging is not in line with the normal practice of .NET
developers.
2. If it is a product environment, long-term log file squeezes can cause
certain issues.
3. The control of log output is not flexible enough.
The more commonly used logging system in .net sdk is
Microsoft.Extensions.Logging.
https://learn.microsoft.com/en-us/dotnet/core/extensions/logging?tabs=command-line
The sdk can expose an API for configuring LoggerFactory, allowing users to
configure it freely.
The design of EF Core can be referenced.
https://learn.microsoft.com/en-us/ef/core/logging-events-diagnostics/extensions-logging?tabs=v3#other-application-types
I tried to modify the logger in rocketmq client. Here is what it looks like
after modification.
```C#
public static class MqLogManager
{
private static ILoggerFactory _loggerFactory;
public static ILogger CreateLogger()
{
return _loggerFactory?.CreateLogger() ?? NullLogger.Instance;
}
public static ILogger CreateLogger(string categoryName)
{
return _loggerFactory?.CreateLogger(categoryName) ??
NullLogger.Instance;
}
public static void UseLoggerFactory(ILoggerFactory loggerFactory)
{
_loggerFactory = loggerFactory ?? throw new
ArgumentNullException(nameof(loggerFactory));
}
}
```
usages:
```C#
MqLogManager.UseLoggerFactory(LoggerFactory.Create(builder =>
{
builder.AddConsole();
}));
public abstract class Client
{
private static readonly ILogger Logger =
MqLogManager.CreateLogger();
protected virtual async Task Start()
{
Logger.LogDebug($"Begin to start the rocketmq client,
clientId={ClientId}");
}
}
```
If possible, I would like to submit a PR, thanks.
GitHub link: https://github.com/apache/rocketmq-clients/discussions/593
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] mxsm added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null
GitHub user mxsm added a comment to the discussion: Cannot invoke "org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.shutdown()" because "this.timerFlushService" is null @RongtongJin @yidazhi 可以看一下这个 ISSUE #7269 . 导致的原因是可能配置的问题导致Broker的某些启动错误。 然后触发退出的操作。在退出过程中 TimerMessageStore 的属性并没有实例化，在执行shutdown的时候空指针了。 @RongtongJin 麻烦review pr代码 GitHub link: https://github.com/apache/rocketmq/discussions/7245#discussioncomment-6887196 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] joeCarf added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy
GitHub user joeCarf added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy 使用的是哪个版本呢 GitHub link: https://github.com/apache/rocketmq/discussions/7291#discussioncomment-6985483 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy
GitHub user alloyinfo added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy 没有堆栈 GitHub link: https://github.com/apache/rocketmq/discussions/7291#discussioncomment-6985167 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xiaokaijunjun closed a discussion: 5.x开启controller模式broker启动失败，NullPointerException
GitHub user xiaokaijunjun closed a discussion: 5.x开启controller模式broker启动失败，NullPointerException 版本：5.1.2 系统：Linux JDK：1.8.0_381 只要broker设置enableControllerMode=true 开启controller，broker启动报错：java.lang.NullPointerException，broker配置单纯把这行去掉broker就能启动，请问是什么原因呢 GitHub link: https://github.com/apache/rocketmq/discussions/7333 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin closed the discussion with a comment: 5.x开启controller模式broker启动失败，NullPointerException
GitHub user RongtongJin closed the discussion with a comment: 5.x开启controller模式broker启动失败，NullPointerException https://github.com/apache/rocketmq/discussions/6928 5.1.2版本存在问题，可以升到5.1.3 GitHub link: https://github.com/apache/rocketmq/discussions/7333#discussioncomment-6985185 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy
GitHub user alloyinfo added a comment to the discussion: java8下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl,jps有namesrv和proxy INFO main - instrumented a special java.util.Set into: sun.nio.ch.EPollSelectorImpl@4eb386 打印的info日志 GitHub link: https://github.com/apache/rocketmq/discussions/7291#discussioncomment-6953415 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xhrg edited a discussion: namesrv前面是否可以绑定LB？？？
GitHub user xhrg edited a discussion: namesrv前面是否可以绑定LB？？？ 如果我使用一个LB负载均衡器，转发到3个namesrv节点。这样肯定是有问题的。因为可能注册broker到namesrv-1节点，而读的时候，lb又可能把请求转发到namesrv-2节点。 如果我对namserv进行改造，实现彼此之间同步数据，那这样是否可以使用LB负载到三个节点。这样我在写namesrv的时候，可以使用域名的方式。 集群切换的时候会方便一些。 GitHub link: https://github.com/apache/rocketmq/discussions/7286 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-docker] peng-huang-ch commented on issue #88: 求助 单机通过docker-compose部署5.1.3
peng-huang-ch commented on issue #88: URL: https://github.com/apache/rocketmq-docker/issues/88#issuecomment-1719541776 `docker-compose.yml` ```sh version: "3" services: #Service for nameserver rmqnamesrv: image: apache/rocketmq:5.1.3 container_name: rmqnamesrv ports: - 9876:9876 environment: JAVA_OPT_EXT: "-server -Xms512M -Xmx512M -Xmn128m" volumes: - ./data/namesrv/logs:/home/rocketmq/logs command: sh mqnamesrv restart: unless-stopped rmqbroker: image: apache/rocketmq:5.1.3 container_name: rmqbroker depends_on: - rmqnamesrv ports: - 10909:10909 - 10911:10911 - 10912:10912 environment: NAMESRV_ADDR: "rmqnamesrv:9876" JAVA_OPTS: " -Duser.home=/opt" JAVA_OPT_EXT: "-server -Xms512M -Xmx512M -Xmn128m" volumes: - ./data/broker/logs:/home/rocketmq/logs - ./data/broker/store:/home/rocketmq/store - ./conf/broker.conf:/opt/conf/broker.conf command: sh mqbroker -c /opt/conf/broker.conf rmqproxy: image: apache/rocketmq:5.1.3 container_name: rmqproxy depends_on: - rmqnamesrv ports: - 8081:8081 environment: NAMESRV_ADDR: "rmqnamesrv:9876" JAVA_OPTS: " -Duser.home=/opt" JAVA_OPT_EXT: "-server -Xms512M -Xmx512M -Xmn128m" volumes: - ./data/proxy/logs:/home/rocketmq/logs - ./data/proxy/store:/home/rocketmq/store - ./conf/proxy.conf:/opt/conf/proxy.conf command: sh mqbroker -c /opt/conf/proxy.conf --enable-proxy dashbord: image: apacherocketmq/rocketmq-dashboard:1.0.0 ports: - 18080:8080 environment: JAVA_OPTS: "-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false -Duser.timezone='Asia/Shanghai'" depends_on: - rmqnamesrv ``` broker.conf & proxy.conf ```conf # 所属集群名字 brokerClusterName=rmqnamesrv # broker 名字，注意此处不同的配置文件填写的不一样，如果在 broker-a.properties 使用: broker-a, # 在 broker-b.properties 使用: broker-b brokerName=broker-a # 0 表示 Master，> 0 表示 Slave brokerId=0 # nameServer地址，分号分割 #namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876 namesrvAddr=rmqnamesrv:9876 # 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed # 解决方式1 加上一句 producer.setVipChannelEnabled(false);，解决方式2 brokerIP1 设置宿主机IP，不要使用docker 内部IP brokerIP1=192.168.31.149 # 在发送消息时，自动创建服务器不存在的topic，默认创建的队列数 defaultTopicQueueNums=4 # 是否允许 Broker 自动创建 Topic，建议线下开启，线上关闭 ！！！这里仔细看是 false，false，false autoCreateTopicEnable=true # 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true # Broker 对外服务的监听端口 listenPort=10911 # 删除文件时间点，默认凌晨4点 deleteWhen=04 # 文件保留时间，默认48小时 fileReservedTime=120 # commitLog 每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue 每个文件默认存 30W 条，根据业务情况调整 mapedFileSizeConsumeQueue=30 # destroyMapedFileIntervalForcibly=12 # redeleteHangedFileInterval=12 # 检测物理文件磁盘空间 diskMaxUsedSpaceRatio=99 # 存储路径 # storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store # commitLog 存储路径 # storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog # 消费队列存储 # storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue # 消息索引存储路径 # storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index # checkpoint 文件存储路径 # storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint # abort 文件存储路径 # abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort # 限制的消息大小 maxMessageSize=65536 # flushCommitLogLeastPages=4 # flushConsumeQueueLeastPages=2 # flushCommitLogThoroughInterval=1 # flushConsumeQueueThoroughInterval=6 # Broker 的角色 # - ASYNC_MASTER 异步复制Master # - SYNC_MASTER 同步双写Master # - SLAVE brokerRole=ASYNC_MASTER # 刷盘方式 # - ASYNC_FLUSH 异步刷盘 # - SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH # 发消息线程池数量 # sendMessageThreadPoolNums=128 # 拉消息线程池数量 # pullMessageThreadPoolNums=12 messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h ``` 启动日志： ```sh docker compose logs --tail=1000 rmqnamesrv rmqnamesrv | OpenJDK 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release rmqnamesrv | OpenJDK 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release. rmqnamesrv | The Name Server boot success. serializeType=JSON, address
[GitHub] [rocketmq] fuyou001 added a comment to the discussion: 事务消息回查相关疑问
GitHub user fuyou001 added a comment to the discussion: 事务消息回查相关疑问 基本不会发生你说的情况。因为sdk发消息时，消息只会发到其中一个broker节点，但在极端场景下，可能同一个消息会发到多个Broker节点上，但在回查事务时，只要应用做好事务回查的幂等逻辑，也不会影响逻辑的正确性。 GitHub link: https://github.com/apache/rocketmq/discussions/7350#discussioncomment-6996216 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？
GitHub user onejimmyboy added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？ 这正常吗？ GitHub link: https://github.com/apache/rocketmq/discussions/7357#discussioncomment-7008919 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl
GitHub user alloyinfo closed the discussion with a comment: java17下搭建rocketMQ，broker_default.log 报instrumneted a sprcial java.util.Set into : sun.nio.ch.EPollSelectorImpl 换了java8也报这个错 GitHub link: https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6902468 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy edited a comment on the discussion: Subscribe some topics by topic pattern
GitHub user onejimmyboy edited a comment on the discussion: Subscribe some topics by topic pattern 看了一下，好像是不支持。支持订阅多个topic，好像不支持模糊匹配 GitHub link: https://github.com/apache/rocketmq/discussions/7297#discussioncomment-6946533 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: Subscribe some topics by topic pattern
GitHub user onejimmyboy added a comment to the discussion: Subscribe some topics by topic pattern 看了一下，好像是不支持 GitHub link: https://github.com/apache/rocketmq/discussions/7297#discussioncomment-6946533 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[I] Run two or more rockermq container in a host set the max heap size. [rocketmq-docker]
xiwolaisi opened a new issue, #93: URL: https://github.com/apache/rocketmq-docker/issues/93 well,when we used docker to run rocketmq two or more container in a host，we found that the max heap size can‘t limited by cgroups. so， why it happened？ -- 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: dev-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] Can not set custom MAX_HEAP_SIZE and HEAP_NEWSIZE [rocketmq-docker]
hq-git opened a new issue, #94: URL: https://github.com/apache/rocketmq-docker/issues/94 **BUG REPORT** 1. Please describe the issue you observed: - I want to run rocketmq container and set a limit for the max heap size. - I want to through adding a docker container environment variable e.g. `MAX_HEAP_SIZE` to set the limit for the max heap size. - The script https://github.com/apache/rocketmq-docker/blob/master/image-build/scripts/runbroker-customize.sh using `calculate_heap_sizes` function to calculate heap size, which often makes the MAX_HEAP_SIZE too large and causing OOM. 2. Please tell us about your environment: - Run multiple rocketmq containers on one host. 4. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): **FEATURE REQUEST** 1. The runbroker-customize.sh function `calculate_heap_sizes` will not overrides the values of `MAX_HEAP_SIZE` and `HEAP_NEWSIZE` variables, when they already have values. -- 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: dev-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Run two or more rockermq container in a host set the max heap size. [rocketmq-docker]
xiwolaisi commented on issue #93: URL: https://github.com/apache/rocketmq-docker/issues/93#issuecomment-1761255934 we found taht max heap size set by https://github.com/apache/rocketmq-docker/blob/master/image-build/scripts/runbroker-customize.sh the script. In this script , linux set max heap size by "free -m" to calculate.But "free -m" will read host /proc/meminfo,it not cgroups limited. we found lxcfs can make it . when you install lxcfs and run it 。 then you run docker run -it --name my_rocketmq -memory=8g -v /var/lib/lxcfs/proc/meminfo:/proc/meminfo:rw apache/rocketmq:4.7.1 and then you wiil found that “free -m” is 8g -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] what kind of expression should be put in subscribe(self, topic, callback, expression='*') [rocketmq-client-python]
ifplusor commented on issue #145: URL: https://github.com/apache/rocketmq-client-python/issues/145#issuecomment-1789000306 There is no plan in the c++ client. Maybe you can look at the [new client project](https://github.com/apache/rocketmq-clients). -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] error Caused by: java.util.concurrent.CancellationException: Task was cancelled. [rocketmq-docker]
HappyAxin commented on issue #90: URL: https://github.com/apache/rocketmq-docker/issues/90#issuecomment-1790300171 Did you solve it? I'm having the same problem now. -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq-client-nodejs] Robert-Ro commented on issue #25: 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言
Robert-Ro commented on issue #25: URL: https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1729068896 @wuteng606 windows的编译环境需要vs2015，这个环境搭建对于我有点麻烦，不知道你有没有构建好的windows rocketmq-client-cpp.dll文件？ -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？
GitHub user RongtongJin added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？ > 如何测试并计算Controller模式的RTO和RPO呐？ RTO：可以用发送消息异常到发送消息正常直接的时间间隔标识 RPO怎么表示那？ 可以衡量切换前后数据是否丢失 GitHub link: https://github.com/apache/rocketmq/discussions/7376#discussioncomment-7069065 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] SpringDay6 edited a discussion: autoCreateTopicEnable=true is not work
GitHub user SpringDay6 edited a discussion: autoCreateTopicEnable=true is not
work
**rocketMq version**: rocketmq-all-5.1.3-bin-release
**client version** : rocketmq-client-java 5.0.5
### producer code :
public static void main(String[] args) throws ClientException {
// 接入点地址，需要设置成Proxy的地址和端口列表，一般是xxx:8081;xxx:8081。
String endpoint = "localhost:8081";
// 消息发送的目标Topic名称，需要提前创建。
String topic = "orderTopic4";
ClientServiceProvider provider = ClientServiceProvider.loadService();
ClientConfigurationBuilder builder =
ClientConfiguration.newBuilder().setEndpoints(endpoint);
ClientConfiguration configuration = builder.build();
// 初始化Producer时需要设置通信配置以及预绑定的Topic。
Producer producer = provider.newProducerBuilder()
.setTopics(topic)
.setClientConfiguration(configuration)
.build();
// Define your message body.
byte[] body = "This is a FIFO message for Apache
RocketMQ".getBytes(StandardCharsets.UTF_8);
String tag = "yourMessageTagA";
final Message message = provider.newMessageBuilder()
// Set topic for the current message.
.setTopic(topic)
// Message secondary classifier of message besides topic.
.setTag(tag)
// Key(s) of the message, another way to mark message besides
message id.
.setKeys("yourMessageKey-1ff69ada8e0e")
// Message group decides the message delivery order.
.setMessageGroup("yourMessageGroup0")
.setBody(body)
.build();
try {
final SendReceipt sendReceipt = producer.send(message);
log.info("Send message successfully, messageId={}",
sendReceipt.getMessageId());
} catch (Throwable t) {
log.error("Failed to send message", t);
}
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
}
**question:** the topic "orderTopic4" not exist,it report a bug with `DESC:
No topic route info in name server for the topic: orderTopic4`
I think i open `the autoCreateTopicEnable=true` but it create the topic ,it
doesn't work
GitHub link: https://github.com/apache/rocketmq/discussions/7378
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] joeCarf added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user joeCarf added a comment to the discussion: autoCreateTopicEnable=true is not work 这是否是一个待完成的功能呢？或是有意设计成这样的吗。如果是功能的话，我可以尝试实现一下 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7069203 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-client-nodejs] Robert-Ro commented on issue #25: 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言
Robert-Ro commented on issue #25: URL: https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1729251394 嗯，好的，感谢 -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] RongtongJin edited a comment on the discussion: autoCreateTopicEnable=true is not work
GitHub user RongtongJin edited a comment on the discussion: autoCreateTopicEnable=true is not work 在RocketMQ 5.0，该参数只有直连broker才生效，连接proxy不生效 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7069077 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-client-nodejs] Robert-Ro commented on issue #25: 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言
Robert-Ro commented on issue #25: URL: https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1729221679 [rocketmq sdk] [info] downloading [https://opensource-rocketmq-client.oss-cn-hangzhou.aliyuncs.com/cpp-client/windows/2.1.0/rocketmq-client-cpp.dll]... │ [rocketmq sdk] [error] error status 403 while downloading [https://opensource-rocketmq-client.oss-cn-hangzhou.aliyuncs.com/cpp-client/windows/2.1.0/rocketmq-client-cpp.dll]. -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq-client-nodejs] wuteng606 commented on issue #25: 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言
wuteng606 commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1729242261
放弃windows吧，用linux子系统吧
| |
武腾
|
|
***@***.***
|
回复的原邮件
| 发件人 | Liutsing ***@***.***> |
| 发送日期 | 2023年09月21日 17:41 |
| 收件人 | ***@***.***> |
| 抄送人 | ***@***.***> ,
***@***.***> |
| 主题 | Re: [apache/rocketmq-client-nodejs] 我用 node-addon-api 封装了
rocketmq-client-cpp 如果有需要可以留言 (Issue #25) |
[rocketmq sdk] [info] downloading
[https://opensource-rocketmq-client.oss-cn-hangzhou.aliyuncs.com/cpp-client/windows/2.1.0/rocketmq-client-cpp.dll]...
│ [rocketmq sdk] [error] error status 403 while downloading
[https://opensource-rocketmq-client.oss-cn-hangzhou.aliyuncs.com/cpp-client/windows/2.1.0/rocketmq-client-cpp.dll].
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you were mentioned.Message ID: ***@***.***>
--
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: dev-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [rocketmq] SpringDay6 edited a discussion: autoCreateTopicEnable=true is not work
GitHub user SpringDay6 edited a discussion: autoCreateTopicEnable=true is not
work
**rocketMq version**: rocketmq-all-5.1.3-bin-release
**client version** : rocketmq-client-java 5.0.5
### producer code :
public static void main(String[] args) throws ClientException {
// 接入点地址，需要设置成Proxy的地址和端口列表，一般是xxx:8081;xxx:8081。
String endpoint = "localhost:8081";
// 消息发送的目标Topic名称，需要提前创建。
String topic = "orderTopic4";
ClientServiceProvider provider = ClientServiceProvider.loadService();
ClientConfigurationBuilder builder =
ClientConfiguration.newBuilder().setEndpoints(endpoint);
ClientConfiguration configuration = builder.build();
// 初始化Producer时需要设置通信配置以及预绑定的Topic。
Producer producer = provider.newProducerBuilder()
.setTopics(topic)
.setClientConfiguration(configuration)
.build();
// Define your message body.
byte[] body = "This is a FIFO message for Apache
RocketMQ".getBytes(StandardCharsets.UTF_8);
String tag = "yourMessageTagA";
final Message message = provider.newMessageBuilder()
// Set topic for the current message.
.setTopic(topic)
// Message secondary classifier of message besides topic.
.setTag(tag)
// Key(s) of the message, another way to mark message besides
message id.
.setKeys("yourMessageKey-1ff69ada8e0e")
// Message group decides the message delivery order.
.setMessageGroup("yourMessageGroup0")
.setBody(body)
.build();
try {
final SendReceipt sendReceipt = producer.send(message);
log.info("Send message successfully, messageId={}",
sendReceipt.getMessageId());
} catch (Throwable t) {
log.error("Failed to send message", t);
}
// Close the producer when you don't need it anymore.
// You could close it manually or add this into the JVM shutdown hook.
// producer.shutdown();
}
**question:** the topic "orderTopic4" not exist,it report a bug with `DESC:
No topic route info in name server for the topic: orderTopic4`
I think i open `the autoCreateTopicEnable=true` but it doesn't create the topic
,it doesn't work
GitHub link: https://github.com/apache/rocketmq/discussions/7378
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-client-nodejs] wuteng606 commented on issue #25: 我用 node-addon-api 封装了 rocketmq-client-cpp 如果有需要可以留言
wuteng606 commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1729192195
你上他们仓库，下载那个dll啊，为啥要自己编译哦。。
| |
武腾
|
|
***@***.***
|
回复的原邮件
| 发件人 | Liutsing ***@***.***> |
| 发送日期 | 2023年09月21日 16:10 |
| 收件人 | ***@***.***> |
| 抄送人 | ***@***.***> ,
***@***.***> |
| 主题 | Re: [apache/rocketmq-client-nodejs] 我用 node-addon-api 封装了
rocketmq-client-cpp 如果有需要可以留言 (Issue #25) |
@wuteng606 windows的编译环境需要vs2015，这个环境搭建对于我有点麻烦，不知道你有没有构建好的windows
rocketmq-client-cpp.dll文件？
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you were mentioned.Message ID: ***@***.***>
--
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: dev-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user RongtongJin added a comment to the discussion: autoCreateTopicEnable=true is not work 在RocketMQ，该参数只有直连broker才生效，连接proxy不生效 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7069077 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？
GitHub user RongtongJin added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？ RPO标志系统能够容忍的最大数据丢失量。所以可以检测消息是否有丢失 GitHub link: https://github.com/apache/rocketmq/discussions/7376#discussioncomment-7093348 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题 1 GitHub link: https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7092300 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] 41405465 edited a comment on the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user 41405465 edited a comment on the discussion: RocektMQ 5.x Proxy
Local 部署的情况下，客户端连接配置问题
c++的5.0版本客户端，这样配 .setEndpoints("10.2.2.2:8081;25.2.25.2:8081");会报错：
GitHub link:
https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7092300
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] liuweiGL closed a discussion: 大佬们请问生产者组（producerGroup）是干嘛的？
GitHub user liuweiGL closed a discussion: 大佬们请问生产者组（producerGroup）是干嘛的？ 我看 spring cloud alibaba 的示例时发现有个 group 配置 https://github.com/alibaba/spring-cloud-alibaba/blob/2823ae7443f05faa075a94cf5375919b627ee08d/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-broadcast-example/rocketmq-broadcast-producer-example/src/main/resources/application.yml#L14 在 `DefaultMQProducer` 中也发现了 `producerGroup` 属性，注释说是事务用到的。但是我看[官网](https://rocketmq.apache.org/zh/docs/domainModel/04producer)只有消费者组的解释，没有提到生产者组概念。请教一下这个我到底要不要配置呢，不配置会对事务有什么影响啊？ GitHub link: https://github.com/apache/rocketmq/discussions/7387 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin closed the discussion with a comment: 大佬们请问生产者组（producerGroup）是干嘛的？
GitHub user RongtongJin closed the discussion with a comment: 大佬们请问生产者组（producerGroup）是干嘛的？ 主要是用于事务消息回查的。事务消息的回查机制，回查时 Broker 端若发现原始生产者连接已经断开，则会联系同一生产者组（producerGroup）的其他生产者实例以 Commit 或 Rollback 半事务消息。 GitHub link: https://github.com/apache/rocketmq/discussions/7387#discussioncomment-7093315 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] RongtongJin added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？
GitHub user RongtongJin added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？ 怎么会有2主1从，是不是1主2从，还是说是1主备 + 一个单主？ GitHub link: https://github.com/apache/rocketmq/discussions/7357#discussioncomment-7093364 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] SpringDay6 added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user SpringDay6 added a comment to the discussion: autoCreateTopicEnable=true is not work 好的，感谢。我直接连接nameServer就可以自动创建主题了。开发环境是不建议的，但是有点强迫症所以想知道原因 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7079883 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] bert82503 added a comment to the discussion: Start RocketMQ on M1 failed
GitHub user bert82503 added a comment to the discussion: Start RocketMQ on M1 failed > Yes, I run it on MacOS with M1, I start successfully when switch version from > 5.1.3 to 5.1.0, will try this way turn off the borker switch related to cold > reading, thanks! we encounter the same issue. @caigy @GenerousMan GitHub link: https://github.com/apache/rocketmq/discussions/7007#discussioncomment-7036915 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] SpringDay6 added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user SpringDay6 added a comment to the discussion: autoCreateTopicEnable=true is not work 文档中哪里有，请给我一个链接 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7069087 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] xdkxlk closed a discussion: Prepare to release Apache RocketMQ 5.1.4
GitHub user xdkxlk closed a discussion: Prepare to release Apache RocketMQ 5.1.4 Hello RocketMQ Community, This is the discussion for the release of Apache RocketMQ 5.1.4 Release. If there are any important pull requests that need to be merged into the 5.1.4 branch, please let me know. GitHub link: https://github.com/apache/rocketmq/discussions/7360 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user onejimmyboy added a comment to the discussion: autoCreateTopicEnable=true is not work 我忘记在那个地方看到了，之前也有社区提出过这个问题，当时有人回复的是不建议支持，应该在实际生成环境中，都是建议关闭这个配置的。 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7076652 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user onejimmyboy added a comment to the discussion: RocektMQ 5.x Proxy
Local 部署的情况下，客户端连接配置问题
客户端配置可以这样写 .setEndpoints("10.2.2.2:8081;25.2.25.2:8081");
另外：如果主从不切换的话，在配置的时候只配置master就可以，如果主从切换的话，需要全配置（个人观点，不知道对不对）。
GitHub link:
https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7076642
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？
GitHub user onejimmyboy added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？ 谢谢回复， 如何进一步测试呐？RPO是否可以理解为数据恢复的时间，是否可以用消费者来测试，启动消费者从消费异常，到消费正常这段时间表示RPO呐？ GitHub link: https://github.com/apache/rocketmq/discussions/7376#discussioncomment-7076586 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy edited a comment on the discussion: autoCreateTopicEnable=true is not work
GitHub user onejimmyboy edited a comment on the discussion: autoCreateTopicEnable=true is not work 我忘记在那个地方看到过，之前也有社区提出过这个问题，当时有人回复的是不建议支持，在实际生成环境中，都是建议关闭这个配置的。 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7076652 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: autoCreateTopicEnable=true is not work
GitHub user onejimmyboy added a comment to the discussion: autoCreateTopicEnable=true is not work 感觉RocketMQ到5.0后，现在的proxy模式，开发文档上面有很多欠缺的，并且和dashboard有一些没有做好适配，dashboard又好长时间没有更新了。心塞啊 GitHub link: https://github.com/apache/rocketmq/discussions/7378#discussioncomment-7076669 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq-docker] zhyblack commented on issue #88: 求助 单机通过docker-compose部署5.1.3
zhyblack commented on issue #88:
URL: https://github.com/apache/rocketmq-docker/issues/88#issuecomment-1740379759
我使用的官方例子也出现了这个问题，解决了
1、play-docker.sh + sh mqbroker --enable-proxy
2、-p 8081:8081 说是 --enable-proxy 会自动启用 8081端口
3、我使用的是阿里云 所以安全组需要放行 8081
然后就搞定了
`Consume message successfully, messageId={}7F0100065910E4409199EB2F`
程序生产者后后台发送消息都没问题
--
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: dev-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [rocketmq-clients] ekkolike added a comment to the discussion: create grpc conn failed, err=context deadline exceeded
GitHub user ekkolike added a comment to the discussion: create grpc conn failed, err=context deadline exceeded the same problem. network is ok. GitHub link: https://github.com/apache/rocketmq-clients/discussions/579#discussioncomment-7150047 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
Re: [I] Push consumer with FIFO message listener [rocketmq-client-csharp]
malus2077 closed issue #23: Push consumer with FIFO message listener URL: https://github.com/apache/rocketmq-client-csharp/issues/23 -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Push consumer with concurrent message listener [rocketmq-client-csharp]
malus2077 closed issue #22: Push consumer with concurrent message listener URL: https://github.com/apache/rocketmq-client-csharp/issues/22 -- 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: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？
GitHub user onejimmyboy added a comment to the discussion: 如何测试并计算Controller模式的RTO和RPO？ 是检测在切换过程中是否有消息丢失？那怎么检测那？在切换过程中无法发消息，这段时间应该不用生成消息吧，就检测切换前和切换成功后这段是否有消息丢失？ GitHub link: https://github.com/apache/rocketmq/discussions/7376#discussioncomment-7107476 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy edited a comment on the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？
GitHub user onejimmyboy edited a comment on the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？ > 怎么会有2主1从，是不是1主2从，还是说是1主备 + 一个单主？ 1主备+1主备，应该叫2主2从，同时注册到一组controller里面，并且同时注册到同一组namesrv中  GitHub link: https://github.com/apache/rocketmq/discussions/7357#discussioncomment-7107373 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？
GitHub user onejimmyboy added a comment to the discussion: RocketMQ5.1.3版本，为什么controller模式2主1从的性能比controller模式1主1从的性能低？ > 怎么会有2主1从，是不是1主2从，还是说是1主备 + 一个单主？ 1主备+1主备，同时注册到一组controller里面，并且同时注册到同一组namesrv中  GitHub link: https://github.com/apache/rocketmq/discussions/7357#discussioncomment-7107373 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy edited a comment on the discussion: 如何测试并计算Controller模式的RTO和RPO？
GitHub user onejimmyboy edited a comment on the discussion: 如何测试并计算Controller模式的RTO和RPO？ 检测切换前后消息是否有丢失？这个怎么检测呀！能给一个思路吗？切换前先预制一部分消息，然后看切换后看这些消息还在不在？ GitHub link: https://github.com/apache/rocketmq/discussions/7376#discussioncomment-7107476 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] onejimmyboy added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user onejimmyboy added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题 看上面的日志解析的host：中间连接的是“，”而不是“；” GitHub link: https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7118169 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题 > 看上面的日志解析的host：中间连接的是“，”而不是“；” 配置是分号";"，","是客户端内部转换的 GitHub link: https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7118594 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] 41405465 deleted a comment on the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user 41405465 deleted a comment on the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题 > 看上面的日志解析的host：中间连接的是“，”而不是“；” 配置是分号";"，","是客户端内部转换的 GitHub link: https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7118594 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题
GitHub user 41405465 added a comment to the discussion: RocektMQ 5.x Proxy Local 部署的情况下，客户端连接配置问题 配置是分号";"，","是客户端内部转换的 GitHub link: https://github.com/apache/rocketmq/discussions/7380#discussioncomment-7118597 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] DseSen edited a discussion: 控制台中，同一个topic下看到有多条相同的MessageID的记录，是延时消息，storeTime不同
GitHub user DseSen edited a discussion: 控制台中，同一个topic下看到有多条相同的MessageID的记录，是延时消息，storeTime不同 控制台中，同一个topic下看到有多条相同的MessageID的记录，是延时消息，storeTime不同  GitHub link: https://github.com/apache/rocketmq/discussions/7403 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
[GitHub] [rocketmq] wangwei-ying added a comment to the discussion: why ConsumerClinet shutdown dot deal START_FAILED status (为什么ConsumerClinet shutdown的时候不处理START_FAILED状态)
GitHub user wangwei-ying added a comment to the discussion: why ConsumerClinet shutdown dot deal START_FAILED status (为什么ConsumerClinet shutdown的时候不处理START_FAILED状态) 1. make a error adress. 2. starConsumer 3. invoke consumer shutdown 4. update adress and consumer again GitHub link: https://github.com/apache/rocketmq/discussions/7369#discussioncomment-7041494 This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
