-
Notifications
You must be signed in to change notification settings - Fork 11.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[ISSUE #8755] batch send support compression #8746
base: develop
Are you sure you want to change the base?
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## develop #8746 +/- ##
=============================================
+ Coverage 47.32% 47.35% +0.02%
- Complexity 11545 11556 +11
=============================================
Files 1282 1282
Lines 89843 89888 +45
Branches 11556 11567 +11
=============================================
+ Hits 42521 42567 +46
+ Misses 42069 42065 -4
- Partials 5253 5256 +3
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
ping @lizhimins for review |
ping @RongtongJin for review |
|
db375b6
to
3db2a85
Compare
3db2a85
to
22c8c07
Compare
closes #8755
Brief Description
by default,
DefaultMQProducer
will compress message body when body length is longer than 4k, but if send with batch(send( Collection<Message> msgs)
), body are not compressed.this pr compress each message body when average length is larger than 4k
How Did You Test This Change?
send and receive batch messages with 8k body(larger than 4k default compress length), check commit log content is compressed. consume message body is 8k length.