-
Notifications
You must be signed in to change notification settings - Fork 11.9k
[ISSUE #4226] Message length exceeds the maximum length when sendback #4338
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
Conversation
Codecov Report
@@ Coverage Diff @@
## develop #4338 +/- ##
=============================================
- Coverage 48.20% 48.15% -0.06%
+ Complexity 5087 5074 -13
=============================================
Files 642 642
Lines 42762 42734 -28
Branches 5596 5590 -6
=============================================
- Hits 20614 20578 -36
- Misses 19637 19647 +10
+ Partials 2511 2509 -2
Continue to review full report at Codecov.
|
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
Outdated
Show resolved
Hide resolved
…for compatibility
There may be other compatibility issues, especially in MessageExtEncoder class
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The code seems OK.
And it is better to add some tests, Sending a message with the body size equal to the maxMessageSize should succeed.
broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
Show resolved
Hide resolved
sure, I will add a unit test. |
…ndback (apache#4338) * fix(bug)msg length exceeds the maximum length when sendback * fix(store) MessageStoreConfig: maxMessageBodySize -> maxMessageSize, for compatibility * style(formatting) commigLog
Make consistent semantics of maxMessageSize, refers to the message body size.
In current version, maxMessageSize refers to message total length not only include message body but also include others fields, such as magic code, queueId, body crc, properties etc.
If we make length limit base on message body, we can get consistent semantics of maxMessageSize easily.