iamgd67 opened a new pull request, #8746:
URL: https://github.com/apache/rocketmq/pull/8746
<!-- Please make sure the target branch is right. In most case, the target
branch should be `develop`. -->
### Brief Description
<!-- Write a brief description for your pull request to help the maintainer
understand the reasons behind your changes. -->
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?
<!-- In order to ensure the code quality of Apache RocketMQ, we expect every
pull request to have undergone thorough testing. -->
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.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
