rocketmq-client-cpp
rocketmq-client-cpp copied to clipboard
apache
Apache RocketMQ cpp client
I want the producer to specify the read/write queue number when it sends a message about a new topic. But in Example, there is no relevant use case. How should...
Seems currently the C++ Client build only support MSVC compiler. Is the C++ Client possible to be built with MinGW in Windows?
==20355== Thread 22: ==20355== Invalid read of size 1 ==20355== at 0x4C35946: __GI_mempcpy (vg_replace_strmem.c:1563) ==20355== by 0x5AF806B: _IO_default_xsputn (in /usr/lib64/libc-2.17.so) ==20355== by 0x5AC8032: vfprintf (in /usr/lib64/libc-2.17.so) ==20355== by 0x5AF3178: vsnprintf...
## What is the purpose of the change Fix build error on aarch64 platform ## Brief changelog The build.sh runs failed on arm64. I checked and fix some error, add...
可靠性和可用性是每个 MQ 系统最重要的两个特性，通过Message Track Trace我们应该查看完整的消息链接，快速找到进程消息传递失败的根本原因，并且可以查询到很多参数值，例如发送成本时间、消费成本时间、存储在 broker 中的时间等等，当服务端压力过大或者存储紧张的时候，我们可以通过命令临时关闭轨迹消息进行降级。Apache RocketMQ在RIP-6中已经实现了消息轨迹的功能，针对CPP客户端，基本的轨迹功能已经实现，需要进一步实现临时降级策略。本题目的目的就是要在CPP客户端实现轨迹降级策略，主要包括： 1.学习Apache RocketMQ知识，详细了解RocketMQ原理、使用方式 2.掌握Apache RocketMQ中轨迹消息特性原理和代码 3.在社区中提交Issue，完成相关代码，review后被社区合并 相关材料： https://github.com/apache/rocketmq-client-cpp https://github.com/apache/rocketmq/wiki/RIP-6-Message-Trace https://github.com/apache/rocketmq/blob/develop/docs/cn/msg_trace/user_guide.md https://rocketmq.apache.org/
**BUG REPORT** 1. Please describe the issue you observed: By opening message trace of c interface，we found question as follows: - Log print error message like : `(error):processSendResponse error remark:topic[rmq_sys_TRACE_DATA_DefaultRegion]...
## What is the purpose of the change #398 ## Brief changelog - Change trace topic to "RMQ_SYS_TRACE_TOPIC" - Add clientId field for Pub trace; Add clientId field for SubBefore...
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...
stack as follow: #0 0x00007f4044b36277 in raise () from /lib64/libc.so.6 #1 0x00007f4044b37968 in abort () from /lib64/libc.so.6 #2 0x00007f40333337d5 in __gnu_cxx::__verbose_terminate_handler() () from /lib64/libstdc++.so.6 #3 0x00007f4033331746 in ?? () from...
see https://github.com/apache/rocketmq-client-cpp/blob/6523dcc3b309a1065375e40657f68f66bfeca38d/src/consumer/SubscriptionData.cpp#L107-L113 the serialize string in rockemq broker is long. i think this should keep the same as broker implementation
