apache / rocketmq-client-cpp

Apache RocketMQ cpp client
https://rocketmq.apache.org/
Apache License 2.0
370 stars 159 forks source link

Watermark #427

Closed SRC-xiaojin closed 2 years ago

SRC-xiaojin commented 2 years ago

What is the purpose of the change

Reduce the times of eventcb callback

Brief changelog

set read water mark to msgLen + 4,wait for receiving whole data; reset read water mark to 4 after user's callback

Verifying this change

the body size of msg is 2k msg count is 1W use Producer.c and PullConsumer.cpp for test As I tested, could reduce latency a litter

Follow this checklist to help us incorporate your contribution quickly and easily. Notice, it would be helpful if you could finish the following 5 checklist(the last one is not necessary)before request the community to review your PR.