Re: [I] [Bug] Timed messages cannot be consumed [rocketmq]

[via GitHub]

github-actions[bot] commented on issue #7641:
URL: https://github.com/apache/rocketmq/issues/7641#issuecomment-2547202375

   This issue was closed because it has been inactive for 3 days since being 
marked as stale.


-- 
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

Re: [I] [Bug] Timed messages cannot be consumed [rocketmq]

[via GitHub]

github-actions[bot] closed issue #7641: [Bug] Timed messages cannot be consumed
URL: https://github.com/apache/rocketmq/issues/7641


-- 
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

Re: [I] [Bug] Timed messages cannot be consumed [rocketmq]

[via GitHub]

github-actions[bot] commented on issue #7641:
URL: https://github.com/apache/rocketmq/issues/7641#issuecomment-2542574410

   This issue is stale because it has been open for 365 days with no activity. 
It will be closed in 3 days if no further activity occurs.


-- 
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

Re: [I] [Bug] Timed messages cannot be consumed [rocketmq]

[via GitHub]

daigoopautoy commented on issue #7641:
URL: https://github.com/apache/rocketmq/issues/7641#issuecomment-1855267379

   ```java
   public MessageExtEncoder(final int maxMessageBodySize) {
   ByteBufAllocator alloc = UnpooledByteBufAllocator.DEFAULT;
   //Reserve 64kb for encoding buffer outside body
   int maxMessageSize = Integer.MAX_VALUE - maxMessageBodySize >= 64 * 
1024 ?
   maxMessageBodySize + 64 * 1024 : Integer.MAX_VALUE;
   byteBuf = alloc.directBuffer(maxMessageSize);
   this.maxMessageBodySize = maxMessageBodySize;
   this.maxMessageSize = maxMessageSize;
   }
   ```
   my config's maxMessageSize=64kb, then maxMessageBodySize=64kb and 
maxMessageSize=128kb
   one delay message bodySize=63kb,  properties=3kb, it can write in commitLog, 
because 63<64, 63+3+other len<128
   
   ```java
   bufferLocal = new ThreadLocal() {
   @Override
   protected ByteBuffer initialValue() {
   // 64kb+100
   return 
ByteBuffer.allocateDirect(storeConfig.getMaxMessageSize() + 100);
   }
   };
   
   private MessageExt getMessageByCommitOffset(long offsetPy, int sizePy) {
   for (int i = 0; i < 3; i++) {
   MessageExt msgExt = null;
   bufferLocal.get().position(0);
   // throw IllegalArgumentException because sizePy>capacity
   bufferLocal.get().limit(sizePy);
   boolean res = messageStore.getData(offsetPy, sizePy, 
bufferLocal.get());
   if (res) {
   bufferLocal.get().flip();
   msgExt = MessageDecoder.decode(bufferLocal.get(), true, 
false, false);
   }
   if (null == msgExt) {
   LOGGER.warn("Fail to read msg from commitLog offsetPy:{} 
sizePy:{}", offsetPy, sizePy);
   } else {
   return msgExt;
   }
   }
   return null;
   }
   ```
   in 
`org.apache.rocketmq.store.timer.TimerMessageStore#getMessageByCommitOffset` , 
this delay message's sizepy=63+3+other len>bufferLocal.capacity=64kb+100, throw 
IllegalArgumentException, cause currQueueOffset cannot update.
   
   I don't know if my opinion is right, wait for your reply, thx. @RongtongJin 
@GenerousMan 


-- 
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

Re: [I] [Bug] Timed messages cannot be consumed [rocketmq]

[via GitHub]

zyhui98 commented on issue #7641:
URL: https://github.com/apache/rocketmq/issues/7641#issuecomment-1853891344

   是消息太大超过我们的maxMessageSize配置的64kb，轮转不了。


-- 
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