tree 136a0eb4fa129f88568468bd1dc79fe516da4efb
parent f1e72d6154332ca69e278005243ae6bde4e8c554
author Yunze Xu <xyzinfernity@163.com> 1642814040 +0800
committer GitHub <noreply@github.com> 1642814040 -0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJh61pYCRBK7hj4Ov3rIwAAopgIAB++2yQLhBfCLQkdec6hjZW5
 xEV+Fd/Oa+t3L6CYnlOXD/gUK23FHig3X4zH9z+fYWvf+IltO3GBRbxV328P4ySX
 yvzMom28E570CIj1QnpgYnM1Q7mVdKv6l4Euh21XciMgpmAomo9zFnyRlLiTEWVV
 /WzR/Cem0MpIg+jnB6Bzt68QWilooFyOBYZsDeXtRCDAREyLVCmzhBKrwoWvXD3k
 LW2IaRzJQuPEFVQv7NNZ1uKiKdKJwzulHs1Xi6zl+Fyp565A7WFY5e19LygPQtgf
 I4gxdQcLmGtXaYqK73S0hEC1j4cVbu+W1aNTGZ1eyqwMkVPpTrT6bjQOWTxxshQ=
 =Lsd6
 -----END PGP SIGNATURE-----
 

[C++] PIP 37: Support large message size (#13627)

* Support configuring chunkingEnabled

* Add limitations when chunking is enabled

* [WIP] serializeAndSendMessage

* Pass TopicName instead of string to ProducerImpl's constructor

* Send messages by chunks

* Check whether the callback should be triggered in sendMessage

* Combine callback and releaseSemaphore

* Wrap the send callback with stats update

* Fix incorrect isValidProducerState

* Fix checksum error when chunks are sent

* Add chunked configs from consumer

* Support consuming chunks

* Fix incorrect concanated payload size

* Add tests for chunking messages

* Fixed tests failure when compression is enabled

* Improve logs

* Refactor chunking related fields and fix memory error

* Fix comments

* Add MapCache class

* Use MapCache to refactor ConsumerImpl

* Verify the chunk cache is cleared

* Fix chunked cache

* Fix CentOS 7 build

* Fix Ubuntu 16.04 build failure

* Fix incompatibility with GTest 1.8.0

* Fix tests

* Fix GCC 5.4 segmentation fault