GitHub user coolmoon101 added a comment to the discussion:
MessageExtEncoder#encode(MessageExtBrokerInner) 计算消息长度是否超过最大允许的消息长度,是不是有问题?
已经找到问题:propertiesLength 这里已经加上了 crc32ReservedLength 的长度
final int propertiesLength = (propertiesData == null ? 0 :
propertiesData.length)
+ (needAppendLastPropertySeparator ? 1 : 0) +
crc32ReservedLength;
GitHub link:
https://github.com/apache/rocketmq/discussions/9169#discussioncomment-12107476
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]