GitHub user biningo added a comment to the discussion: 发送消息报错No topic route info
1、直接在运维页面配置或者启动的时候传参，dashboard的配置可参考官方文档：https://github.com/apache/rocketmq-dashboard/blob/master/docs/1_0_0/UserGuide_CN.md
2、你这个报错是一些指标数据落盘的报错，可以排查下，或者先关闭enableDashBoardCollect开关先让dashboard正常run起来
GitHub user biningo deleted a comment on the discussion: 发送消息报错No topic route
info
1、直接在运维页面配置或者启动的时候传参，dashboard的配置可参考官方文档：https://github.com/apache/rocketmq-dashboard/blob/master/docs/1_0_0/UserGuide_CN.md
2、你这个报错是一些指标数据落盘的报错，可以排查下，或者先关闭enableDashBoardCollect开关先让dashboard正常run起来
GitHub user biningo added a comment to the discussion: 发送消息报错No topic route info
1、直接在运维页面配置或者启动的时候传参，dashboard的配置可参考官方文档：https://github.com/apache/rocketmq-dashboard/blob/master/docs/1_0_0/UserGuide_CN.md
2、你这个报错是一些指标数据落盘的报错，可以排查下，或者先关闭enableDashBoardCollect开关先让dashboard正常run起来
GitHub user cpupg added a comment to the discussion: 发送消息报错No topic route info
破案了，和上面说的没关系，实际原因是`MessageListener#consume`这个方法里出现异常，然后在`org.apache.rocketmq.client.java.impl.consumer.ConsumeTask#call`这个方法里有这么一行：
```java
log.error("Message listener raised an exception while consuming messages,
naah69 opened a new issue, #148:
URL: https://github.com/apache/rocketmq-client-python/issues/148
目前的rocketmq-client-cpp包含以下俩个问题
1. https://github.com/apache/rocketmq-client-cpp/issues/456
2.
https://github.com/apache/rocketmq-client-cpp/issues/293#issuecomment-2050991644
GitHub user leizhiyuan added a comment to the discussion: [Bug] Bug title
java客户端发送消息一直阻塞
你可以自己抓包，看看服务端返回没有，也可以让阿里云的工单给你从服务端抓包。
GitHub link:
https://github.com/apache/rocketmq/discussions/8016#discussioncomment-9079508
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user astorage added a comment to the discussion: [Bug] Bug title
java客户端发送消息一直阻塞
现象是这样。
GitHub link:
https://github.com/apache/rocketmq/discussions/8016#discussioncomment-9079494
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an
GitHub user leizhiyuan added a comment to the discussion: [Bug] Bug title
java客户端发送消息一直阻塞
建议找阿里云的工单进行定位，这个看上去很像是服务端写入了，但是服务端没有返回response。
GitHub link:
https://github.com/apache/rocketmq/discussions/8016#discussioncomment-9079483
This is an automatically sent email for
GitHub user astorage added a comment to the discussion: [Bug] Bug title
java客户端发送消息一直阻塞
好的，我找他们先看看
GitHub link:
https://github.com/apache/rocketmq/discussions/8016#discussioncomment-9079517
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send 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 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 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 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 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 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 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
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 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 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 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 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 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 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 biningo added a comment to the discussion:
不同的消费者订阅同一个topic的不同tag，消息多的tag是否会影响消息少tag的消费速度
同一个消费者组的话，里面的消费者的订阅关系必须是一致的，文档：https://rocketmq.apache.org/docs/bestPractice/05subscribe
你指的是不同的消费者组订阅不同的tag是否会互相影响？这必然不会，每个消费者组都相当于是独立的
GitHub link:
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
jiaklop9 commented on issue #107:
URL:
https://github.com/apache/rocketmq-client-python/issues/107#issuecomment-2056100145
other asyncio coroutine need callback data, how to get it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
codefromthecrypt commented on issue #98:
URL: https://github.com/apache/rocketmq-docker/issues/98#issuecomment-2052288514
p.s. even without arm pipeline, we can still publish multi-platform on x86
runner with buildx.
here's an example, though not sure activemq pipeline
GitHub user cgeffect added a comment to the discussion: 5.x cpp
clients是依赖特定的版本的第三方库么？
我使用grpc 1.46.2, openssl的OpenSSL_1_1_1q 版本和rocketmq5.0.1 可以编译成功, 但是链接失败. 一步一个坑啊.
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/590#discussioncomment-9149562
This is an
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:
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 {
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:
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 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 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 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 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 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: 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 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 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
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 panxd98 edited a discussion: RocketMQ5 Proxy 将消息写入remotingCommand
我现在在开发一个Proxy的功能，需要对消费消息请求的response中的消息进行修改。
其中将response转为msgList可以用这个方法:
```
List
msgList=MessageDecoder.decodesBatch(ByteBuffer.wrap(response.geteBody()),true,true,true);
```
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 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
原因找到了，msg修改了内容后没有把StoreSize的值设为0，导致转换为byte数组的时候数组最后多了好几个0，然后客户端解析的时候就把第一条之后的都忽略了，在转换为byte数组前加一个这样的代码就可以了：
```
msg.setStoresize(0);
```
GitHub link:
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 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 Willhow-Gao closed a discussion:
ConsumeMessageOrderlyService消费消息时，对processQueue的consumeLock加读锁的作用是什么
看网上的资料都说加锁是为了防止当前consumer还在消费，且没有提交位移时发生了重平衡，正在消费的messagequeue被分配给了其他消费者，导致重复消费。但是通过阅读源码发现，在发生锁争抢时，processQueue是dropped状态，即使加了读锁保证消费完了才继续重分配，消费位移还是无法被提交。还是我理解有误？
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 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 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 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
fengqileen commented on issue #619:
URL:
https://github.com/apache/rocketmq-externals/issues/619#issuecomment-1985154156
有什么解决方案吗？
--
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 quanzhou88 added a comment to the discussion: >mqadmin
queryMsgByUniqueKey execute error
那请问还有其他方式查询 ，消息是否被消费吗？
GitHub link:
https://github.com/apache/rocketmq/discussions/7889#discussioncomment-8702501
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user oopooa edited a discussion: Node.js client can't send message
I'm currently working with RocketMQ 5.2.0 and trying to get my Node.js client
to connect and send messages. This
[client](https://github.com/apache/rocketmq-clients/tree/master/nodejs) was
just released a few days ago.
ddatsh closed issue #902: [rocketmq-es-apm] hope support es-apm-mq
URL: https://github.com/apache/rocketmq-externals/issues/902
--
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.
GitHub user caigy added a comment to the discussion: 部署 3 节点 controller ，broker
状态 alive 显示为 false
broker和controller间的网络正常吗？broker中controller相关的环境变量提供一下。
GitHub link:
https://github.com/apache/rocketmq/discussions/7877#discussioncomment-8740604
This is an automatically sent email for
GitHub user drivebyer added a comment to the discussion: 部署 3 节点 controller
，broker 状态 alive 显示为 false
BTW, 我用的 yaml 是：
```
apiVersion: v1
kind: ConfigMap
metadata:
name: broker-config
data:
# BROKER_MEM sets the broker JVM, if set to "" then Xms = Xmx = max(min(1/2
ram, 1024MB), min(1/4
GitHub user drivebyer added a comment to the discussion: 部署 3 节点 controller
，broker 状态 alive 显示为 false
在两个 broker 中用 nc 命令测试到 controller 的端口都是通的：
```
bash-4.4# nc -zv 192.168.84.246 9878
192.168.84.246 (192.168.84.246:9878) open
bash-4.4# nc -zv 192.168.137.114 9878
192.168.137.114
GitHub user bingfan1005 added a comment to the discussion: 事务消息提交后依然会出现回查
问题解决了吗 是什么原因啊 ？ 我也遇见了
GitHub link:
https://github.com/apache/rocketmq/discussions/7002#discussioncomment-8821919
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an
GitHub user pxd98 closed the discussion with a comment: rocketmq5 proxy 的兼容性问题
好的，谢谢
GitHub link:
https://github.com/apache/rocketmq/discussions/7919#discussioncomment-8824480
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
supery-chen commented on issue #94:
URL: https://github.com/apache/rocketmq-docker/issues/94#issuecomment-2002754170
+1
--
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
GitHub user 41405465 edited a discussion: rocketmq5.x版本cpp
grpc客户端，producer生产消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker
rocketmq5.x版本cpp客户端，producer生产消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker，不知道啥问题
rocketmq集群部署方式：
3 master + 3 salve，6台机器都开启proxy方式，producer客户端EndPoint配置6个broker的 ip+
GitHub user 41405465 edited a discussion: rocketmq5.x版本cpp
grpc客户端，producer生产消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker
rocketmq5.x版本cpp
grpc客户端，producer生产消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker，不知道啥问题
rocketmq集群部署方式：
3 master + 3 salve，6台机器都开启proxy方式，producer客户端EndPoint配置6个broker的
fanandli opened a new issue, #147:
URL: https://github.com/apache/rocketmq-client-python/issues/147
i write a code like that:
```python
from multiprocessing import Process
from rocketmq.client import Producer, Message, PushConsumer, ConsumeStatus
import time
import json
GitHub user LittleBoy18 edited a discussion: pop消费模式下消费速度和消费者数量以及topic
queue数量的关系
pop消费的时候broker会给queue加锁，理论上增加queue的数量会避免锁的竞争，消费速度会有明显提高，按照以下用例测试消费速度无明显提高，用例如下：
1、topic单queue，四个消费者同时进行pop消费
2、topic四个queue，四个消费者同时进行pop消费
pop消费模式下，消费速度只和消费者数量有关系不用考虑queue的数量吗？
GitHub link:
GitHub user 1025044866xxy added a comment to the discussion: 批量拉取数量不对
上面的设置是生效的，我发现部分机器会拉满数据，部分不可以，还在找原因。
GitHub link:
https://github.com/apache/rocketmq/discussions/7596#discussioncomment-8828854
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please
treelly commented on issue #115:
URL:
https://github.com/apache/rocketmq-client-python/issues/115#issuecomment-2005672590
您好，邮件已收到！
--
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
Ava-yjt commented on issue #115:
URL:
https://github.com/apache/rocketmq-client-python/issues/115#issuecomment-2005672130
卸载rocketmq-client-python和rocketmq
重新安装rocketmq-client-python和rocketmq-client-cpp，成功解决了这个问题
猜测是新版的rocketmq-client-python和rocketmq包有冲突，只需要安装前者就行
--
This is an
GitHub user pxd98 added a comment to the discussion: rocketmq SDK的使用
这个应该是看你上层的请求，如果你的请求是往nameserver发的，应该填null，如果往broker发的，就填broker的url。
比如你这个请求是sendmessage，就应该是填brokerurl，如果你的请求是查询topic的路由信息，就应该填null。
如果仅仅是使用这个sdk的话，应该直接用类似于producer.setNamesrvAddr(“namesrvAddr”)就可以了，sdk里会自动帮你判断的；除非你是想直接用这个接口。
GitHub user pxd98 added a comment to the discussion: QuickStart Demo ERROR:
Task was cancelled.
是不是因为你的broker在windows机器上跑的。
producer或者proxy发送消息的步骤简单可以分为两步，第一步是去nameserver获取这个topic的路由信息，第二步是往路由信息中拿到的broker地址直接发送。这个broker的地址在不设置的情况下是这里代码
GitHub user scwlkq added a comment to the discussion: rocketmq SDK的使用
我在使用RemotingClient的时候出现了一些问题，可以请您看下这段代码有什么问题吗 非常感谢
GitHub link:
GitHub user leizhiyuan added a comment to the discussion: rocketmq5 proxy 的兼容性问题
升级到4.9.x 最新版本，低版本不兼容
GitHub link:
https://github.com/apache/rocketmq/discussions/7919#discussioncomment-8783751
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send
GitHub user scwlkq deleted a comment on the discussion: rocketmq SDK的使用
我在使用RemotingClient的时候出现了一些问题，可以请您看下这段代码有什么问题吗 非常感谢
GitHub link:
GitHub user scwlkq added a comment to the discussion: rocketmq SDK的使用
我在使用RemotingClient的时候遇到了一些问题， 可以帮忙看下么 非常感谢
用DefaultAdminExt是可以成功的 所以mq应该没啥问题
GitHub link:
canghailan commented on issue #90:
URL: https://github.com/apache/rocketmq-docker/issues/90#issuecomment-1994176620
用docker部署rocketmq遇到了同样的问题，启动broker时去掉--enable-proxy，独立部署proxy就没有问题了
GitHub user cj495840252 edited a discussion: Error: The message queue is not in
assigned list, may be rebalancing
求助大佬，我用DefaultLitePullConsumer创建consumer的后调用seekToBegin和seekToEnd方法都会报这个错,
java lib rocketmq-client: 5.0.0
rocketmq: 5.0.0
```java
public class Main {
private final static
GitHub user cj495840252 edited a discussion: Error: The message queue is not in
assigned list, may be rebalancing
求助大佬，我用DefaultLitePullConsumer创建consumer的后调用seekToBegin和seekToEnd方法都会报这个错,
java lib rocketmq-client: 5.0.0
rocketmq: 5.0.0
```java
public class Main {
private final static
GitHub user cj495840252 edited a discussion: Error: The message queue is not in
assigned list, may be rebalancing
求助大佬，我用DefaultLitePullConsumer创建consumer的后调用seekToBegin和seekToEnd方法都会报这个错,
java lib rocketmq-client: 5.0.0
rocketmq: 5.0.0
```java
public class Main {
private final static
GitHub user pxd98 closed a discussion: rocketmq5 proxy 的兼容性问题
我的服务端是5.2.0，客户端是4.9.1，在发送消息的时候报了 15 Request doesn't have field
bname的报错，我看proxy里的源码是需要判断请求里是否存在bname这个字段
```
if (request.getCode() == RequestCode.SEND_MESSAGE_V2) {
if
GitHub user SimonLiuhd closed a discussion: 4.x在4.9.8之后还会出新版本吗？
4.9.8的end of support是2024.03，之后有安全漏洞或者bug会持续出新版本吗？
GitHub link: https://github.com/apache/rocketmq/discussions/7913
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
GitHub user RongtongJin closed the discussion with a comment:
4.x在4.9.8之后还会出新版本吗？
基本不会了，除非有特殊情况，建议升级到5.x。
GitHub link:
https://github.com/apache/rocketmq/discussions/7913#discussioncomment-8785314
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please
GitHub user MmringZee added a comment to the discussion: message store is not
writeable, so putMessage is forbidden
yaml是不是不该直接以代码的形式放进来...
GitHub link:
https://github.com/apache/rocketmq/discussions/7950#discussioncomment-8869928
This is an automatically sent email for
GitHub user MmringZee edited a discussion: message store is not writeable, so
putMessage is forbidden
我在使用官方quickstart提供的demo访问部署在k8s上的单节点mq时,程序报错:
`2024-03-22T02:43:27.134+08:00 ERROR 1 --- [nio--exec-2]
c.p.r.controller.ProduceController : Failed to send message
GitHub user MmringZee deleted a comment on the discussion: message store is not
writeable, so putMessage is forbidden
yaml是不是不该直接以代码的形式放进来...
GitHub link:
https://github.com/apache/rocketmq/discussions/7950#discussioncomment-8869928
This is an automatically sent email for
GitHub user cserwen edited a comment on the discussion:
pop消费模式下消费速度和消费者数量以及topic queue数量的关系
锁竞争影响性能，理论上得需要很高并发，4个并发显然不够，并且 Broker 处理拉取请求的并发是有限制的，默认最多会有 32
个线程在竞争，我理解也不严重（每个拉取请求获取锁后都是从内存中读数据，速度非常快，并不会长期持有锁）
况且很多时候消费瓶颈不在拉取上，而在消费逻辑上，从生产环境数据来看，一般每个 Broker 上设置单个 queue 足够
GitHub link:
GitHub user cserwen added a comment to the discussion:
pop消费模式下消费速度和消费者数量以及topic queue数量的关系
锁竞争影响性能，理论上得需要很高并发，4个并发显然不够，并且 Broker 处理拉取请求的并发是有限制的，默认最多会有 32
个线程在竞争，我理解也不严重（每个拉取请求获取锁后都是从内存中读数据，速度非常快，并不会长期持有锁）
况且很多时候消费瓶颈不在拉取上，而在消费逻辑上，从生产环境数据来看，一般采用单个 queue 足够
GitHub link:
GitHub user jimchanghub added a comment to the discussion: [RocketMQ 5.1.4]
内外网隔离的情况下，怎么做到内外网都可以通过MQ收发消息
我也碰到同样的问题了，请问有办法解决吗
GitHub link:
https://github.com/apache/rocketmq/discussions/7558#discussioncomment-8873224
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user asjfoajs added a comment to the discussion: [RocketMQ 5.1.4]
内外网隔离的情况下，怎么做到内外网都可以通过MQ收发消息
可以尝试修改一下在broker.conf 上加上一行brokerIP1 = 你的外网ip
GitHub link:
https://github.com/apache/rocketmq/discussions/7558#discussioncomment-8875777
This is an automatically sent email for
GitHub user asjfoajs deleted a comment on the discussion: [RocketMQ 5.1.4]
内外网隔离的情况下，怎么做到内外网都可以通过MQ收发消息
可以尝试修改一下在broker.conf 上加上一行brokerIP1 = 你的外网ip
GitHub link:
https://github.com/apache/rocketmq/discussions/7558#discussioncomment-8875777
This is an automatically sent email for
GitHub user elvislou edited a discussion: rocketmq broker没有响应
各位老师好，有个rocketmq的问题请教一下：
问题现象：在生产环境中，会偶发（一两个月发生一次）rocketmq消息发送超时问题，客户端日志报sendDefaultImpl call
timeout，此问题一直持续，此时，pull消息也会发生超时，直到重启客户端应用才能恢复正常。
就是应用到这个broker上的这个tcp连接上，客户端发送的请求，服务端broker始终没有返回，导致客户端超时。
RocketMQ版本:4.5.1
问题分析线索：
GitHub user letian-tang added a comment to the discussion: 批量拉取数量不对
我也遇到同样的问题，后来解决没有啊？
GitHub link:
https://github.com/apache/rocketmq/discussions/7596#discussioncomment-8799662
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to:
701 - 800 of 896 matches
Mail list logo
