You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "ni-ze (via GitHub)" <gi...@apache.org> on 2023/05/04 01:54:42 UTC

[GitHub] [rocketmq-streams] ni-ze commented on issue #287: 会消费RocketMQStream创建前的消息

ni-ze commented on issue #287:
URL: https://github.com/apache/rocketmq-streams/issues/287#issuecomment-1533976330

   @longbowen 
   我没有复现你说的能消费到RocketMQStream创建之前的消息，能告诉下具体复现步骤吗？
   我的步骤：
   
   1. 启动RocketMQ 5.0
   2. 向source topic中写入数据；
   3. 运行wordcount例子；
   4. 再向source topic中写入数据；
   5. 计算结果如下：the出现5次而不是10次
   ![image](https://user-images.githubusercontent.com/31175234/236092666-8377f92d-fe85-44df-8a88-37c39c7be55f.png)
   


-- 
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-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org