rocketmq-client-cpp

rocketmq-client-cpp copied to clipboard

$ make rocketmq_shared -j

2

The issue tracker is **ONLY** used for the CPP/C client (feature request of RocketMQ need to follow [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal)). Keep in mind, please check whether there is an existing same...

zhaokaiping-github

问题： 多线程并发调用 producer->send() 很容易得到错误消息：GetTransport of:xxx get timed_mutex timeout 除了libevent的版本问题，还有一个原因是gcc版本的bug 原因： if (!lock.try_lock_for(std::chrono::seconds(m_tcpTransportTryLockTimeout))) { LOG_ERROR("GetTransport of:%s get timed_mutex timeout", addr.c_str()); std::shared_ptr pTcp; return pTcp; } gcc4.8.5的情况下，try_lock_for会立即返回，并不会等待期待的m_tcpTransportTryLockTimeout时长。 升级到4.9.0之后即可解决。 **std::timed_mutex::try_lock_for bug： https://gcc.gnu.org/bugzilla/show_bug.cgi?id=54562** @ShannonDing...

button-chen

When there is a large amount of message accumulation, the consumer's callback function will retrieve multiple messages at once, ranging from 1 to 32, but the maximum is 32 this...

cgeffect

Why there is no content in function “void DefaultMQPullConsumerImpl::fetchMessageQueuesInBalance”? wheather to support?

liufuda

批量消息体格式异常：SOH ，STX
{
{"a":1,"uKey":"DeviceLogEvent","deviceModelId":"1036598151955419136","commonEventClass":"","level":"","eventType":"DeviceLogEvent","serverIp":"10.42.33.107","driverId":"1036598288685535232","enterpriseId":"715155051637899264","date":"2022-11-27 10:20:49.394"}bKEYS
gatewayUID:undefinedTAGS
DeviceLogEventUNIQ_KEY
0A2A216B00081BCD450B881DB9740000WAIT
true
{
{"b":2,"uKey":"DeviceLogEvent","deviceModelId":"1036598151955419136","commonEventClass":"","level":"","eventType":"DeviceLogEvent","serverIp":"10.42.33.107","driverId":"1036598288685535232","enterpriseId":"715155051637899264","date":"2022-11-27 10:20:49.394"}bKEYS
gatewayUID:undefinedTAGS
DeviceLogEventUNIQ_KEY
0A2A216B00081BCD450B881DB9740001WAIT
true 

eric-projects

Got crash when calling rocketmq::LogUtil::LogMessageFull

2

1. Please describe the issue you observed: Since Jul 13 2021, our rmq-client-cpp was really stable in the production environment, it's version is "2.2.0"; but got crashed today, below is...

wxyBUPT

Fixing the issue of rocketmq-client-app failing to build on Mac M1 and M2 environments.

2

The issue is that Mac M1 and M2 no longer support openssl-1.1.1, causing a compilation error related to arm64 during the build process. To resolve this, openssl needs to be...

zhangpan-soft

DefaultMQProducer发送消息时，当网络延迟3S时，程序直接崩溃

9

系统：CentOS7 下图是测试代码：  下图为rocketmq_client.log日志内容：  下图为Coredump文件的调用堆栈息：  请大神看到帮忙解决一下，谢谢！@

HUHANK

能否release一个 支持mac m3 的 构建后的包 非常感谢

4

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: dlopen(/usr/local/lib/librocketmq.dylib, 0x0006): tried: '/usr/local/lib/librocketmq.dylib' (mach-o file, but is an incompatible architecture (have 'x86_64', need 'arm64')), '/System/Volumes/Preboot/Cryptexes/OS/usr/local/lib/librocketmq.dylib' (no such file), '/usr/local/lib/librocketmq.dylib' (mach-o file, but is an...

Yifan200809

Does the rockermq-client-python support IPv6?

1

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 in...

Jasongsq