Hello
1、 The Rocketmq send compress message when the message size bigger than 4*1024 
,you choose JDK deflate algorithm and set default level is                5,I 
feel puzzled at  this level, why 5? why not 4,,why not 3 .....,whether not lz4 
replace defate?
2、In DefaultMessageStore#putMessage  method :
long beginTime = this.getSystemClock().now();
PutMessageResult result = this.commitLog.putMessage(msg);

long eclipseTime = this.getSystemClock().now() - beginTime;
if (eclipseTime > 500) {
log.warn("putMessage not in lock eclipse time(ms)={}, bodyLength={}", 
eclipseTime, msg.getBody().length);
}
eclipseTime ? what do u mean?

Reply via email to