liudezhi2098 opened a new issue #6403: when send a delayed message, there is a case pull duplicate messages URL: https://github.com/apache/pulsar/issues/6403 **Describe the bug** when send a delayed message ,there is a case when a consumer restarts and pull duplicate messages. **To Reproduce** 1、send message ``` MessageId msgId = producer.newMessage() .value("my-async-message".getBytes()) .deliverAfter(5000, TimeUnit.MILLISECONDS) .send(); System.out.println(msgId.getMessageId()) ``` Console ``` msgId=405:0:-1 ``` 2、Stop consumers in 5000ms, just produced message hasn't arrived 3、start conumers， then get two same messages，this is we do not want ``` do { Message msg = consumer.receive(); System.out.println(msg.getMessageId()) } while (true); ``` Console ``` 405:0:-1 405:0:-1 ```
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
