rocketmq-client-cpp
rocketmq-client-cpp copied to clipboard
apache
Apache RocketMQ cpp client
original issue: https://ask.csdn.net/questions/4332269 error log info ------------------------------------------------------------------------------------ (error): [7f0c4dffb700] no corresponding consumer found for group:TEST_TOPIC_PULL[consumerRunningInfo:1203] (error): [7f0ac37fe700] GetTransport of:172.20.0.232:30911 get timed_mutex timeout[CreateTransport:307] (error): [7f0ac37fe700] send failed of times:1,brokerName:broker0[sendDefaultImpl:424] (error): [7f0ac37fe700]...
1. The log directory cannot be configured 2. The log file name should distinguish the year, month and day 3. Delete all log files in the log directory, new logs...
The re-dev branch cannot be compiled under windows The project in the win32 folder is actually wrong. Many files have been deleted, but they are still in the project. I...
**BUG REPORT** The running result will be like（both master an release 2.2）: ``` ./SyncProducer -n XX -g XX -t XX -i XX -T 2 nameserver: XX topic: XX groupname: XX...
string terminator '\0' should be considered here: https://github.com/apache/rocketmq-client-cpp/blob/9008c14d9c34a4f0b4a67417000612348157027e/src/common/ClientRPCHook.cpp#L56 I use `valgrind` to run my program, it always prompts the following error. According to the source code, this should be because...
https://github.com/apache/rocketmq-client-cpp/blob/a42de735a3319a859f6108c9e714ed715fe45969/src/consumer/DefaultMQPullConsumerImpl.cpp#L290
OS: Centos7 client version:2.2.0 RocketMQ version:4.7.1 ----------------------test code------------------------------- #include #include #include #include #include "CPushConsumer.h" #include "CMessageExt.h" #include using namespace std; // consume message int doConsumeMessage(struct CPushConsumer *consumer, CMessageExt *msgExt) {...
After deleting the log file in the log directory, it will crash at 0 o'clock the next day！ OS: CentOS Linux release 7.5.1804 (Core) (gdb) where #0 0x00007f145123e277 in raise...
Why is there no interface for setting the log file name and log path？ After my program restarts, the disk is easily filled with rocketmq client logs。
