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

Posted to commits@rocketmq.apache.org by "onejimmyboy (via GitHub)" <gi...@apache.org> on 2023/03/21 06:58:56 UTC

[GitHub] [rocketmq] onejimmyboy opened a new issue, #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

onejimmyboy opened a new issue, #6427:
URL: https://github.com/apache/rocketmq/issues/6427

The issue tracker is used for bug reporting purposes **ONLY** whereas feature request needs to follow the [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal). To avoid unnecessary duplication, please check whether there is a previous issue before filing a new one.

It is recommended to start a discussion thread in the [mailing lists](http://rocketmq.apache.org/about/contact/) or [github discussions](https://github.com/apache/rocketmq/discussions) in cases of discussing your deployment plan, API clarification, and other non-bug-reporting issues.
We welcome any friendly suggestions, bug fixes, collaboration, and other improvements.

Please ensure that your bug report is clear and self-contained. Otherwise, it would take additional rounds of communication, thus more time, to understand the problem itself.

Generally, fixing an issue goes through the following steps:
1. Understand the issue reported;
1. Reproduce the unexpected behavior locally;
1. Perform root cause analysis to identify the underlying problem;
1. Create test cases to cover the identified problem;
1. Work out a solution to rectify the behavior and make the newly created test cases pass;
1. Make a pull request and go through peer review;

As a result, it would be very helpful yet challenging if you could provide an isolated project reproducing your reported issue. Anyway, please ensure your issue report is informative enough for the community to pick up. At a minimum, include the following hints:

**BUG REPORT**

1. Please describe the issue you observed:
Dledger Model ，When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?
Put this pr into 5.1.0 and repackage it.
[ISSUE #5883] DLedger commit log should override the getData (#5879)
- What did you do (The steps to reproduce)?

- What is expected to see?

- What did you see instead?

2. Please tell us about your environment:

3. Other information (e.g. detailed explanation, logs, related issues, suggestions on how to fix, etc):

**FEATURE REQUEST**

1. Please describe the feature you are requesting.

2. Provide any additional detail on your proposed use case for this feature.

3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue?

4. If there are some sub-tasks involved, use -[] for each sub-task and create a corresponding issue to map to the sub-task:

- [sub-task1-issue-number](example_sub_issue1_link_here): sub-task1 description here,
- [sub-task2-issue-number](example_sub_issue2_link_here): sub-task2 description here,
- ...

--
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.apache.org

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

[GitHub] [rocketmq] onejimmyboy commented on issue #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

Posted by "onejimmyboy (via GitHub)" <gi...@apache.org>.

onejimmyboy commented on issue #6427:
URL: https://github.com/apache/rocketmq/issues/6427#issuecomment-1477407589

   > @onejimmyboy Is it an arbitrary precision delay message in 5.0 or is it related to the delay level?
   
   it is arbitrary precision delay message, delay level no problem


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

[GitHub] [rocketmq] keranbingaa commented on issue #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

Posted by "keranbingaa (via GitHub)" <gi...@apache.org>.

keranbingaa commented on issue #6427:
URL: https://github.com/apache/rocketmq/issues/6427#issuecomment-1538450613

   I test arbitrary precision delay message in dledger mode, but it seems failed. https://github.com/apache/rocketmq/pull/5879  is this pr fix this problem?


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

[GitHub] [rocketmq] onejimmyboy commented on issue #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

Posted by "onejimmyboy (via GitHub)" <gi...@apache.org>.

onejimmyboy commented on issue #6427:
URL: https://github.com/apache/rocketmq/issues/6427#issuecomment-1477366550

   消费者demo
   import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
   import org.apache.rocketmq.spring.core.RocketMQListener;
   import org.apache.rocketmq.spring.core.RocketMQReplyListener;
   import org.springframework.beans.factory.annotation.Value;
   import org.springframework.stereotype.Component;
   
   @Component
   @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.group}", topic = "${consumer.topic}")
   public class RocketMQConsumer001 implements RocketMQListener<String> {
       @Value("${consumer.topic}")
       private String topicName;
       @Value("${rocketmq.consumer.group}")
       private String groupName;
   
       @Override
       public void onMessage(String s) {
           System.out.println("groupName :" + groupName + "：from topicName: " + topicName+",监听的消息内容为："+s);
       }
   }


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

[GitHub] [rocketmq] onejimmyboy commented on issue #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

Posted by "onejimmyboy (via GitHub)" <gi...@apache.org>.

onejimmyboy commented on issue #6427:
URL: https://github.com/apache/rocketmq/issues/6427#issuecomment-1539696627

   是的
   
   
   
   
   ヤ艾枫o.--
   ***@***.***
   
   
   
   &nbsp;
   
   
   
   
   ------------------&nbsp;原始邮件&nbsp;------------------
   发件人:                                                                                                                        "apache/rocketmq"                                                                                    ***@***.***&gt;;
   发送时间:&nbsp;2023年5月8日(星期一) 晚上10:23
   ***@***.***&gt;;
   ***@***.******@***.***&gt;;
   主题:&nbsp;Re: [apache/rocketmq] Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it? (Issue #6427)
   
   
   
   
   
    
   I test arbitrary precision delay message in dledger mode, but it seems failed. #5879  is this pr fix this problem?
    
   —
   Reply to this email directly, view it on GitHub, or unsubscribe.
   You are receiving this because you were mentioned.Message ID: ***@***.***&gt;


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

[GitHub] [rocketmq] RongtongJin commented on issue #6427: Dledger Model。When a user consumes a delay message for an arbitrary period of time, when the broker performs a master-slave switch, will they repeatedly consume it?

Posted by "RongtongJin (via GitHub)" <gi...@apache.org>.

RongtongJin commented on issue #6427:
URL: https://github.com/apache/rocketmq/issues/6427#issuecomment-1477403284

   @onejimmyboy Is it an arbitrary precision delay message in 5.0 or is it related to the delay level?


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