You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/09/18 12:32:32 UTC
[GitHub] [pulsar] vvijayv opened a new issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
vvijayv opened a new issue #12091:
URL: https://github.com/apache/pulsar/issues/12091
**Describe the bug**
When consumers loose the messages that were supposed to be delayed messages when they are offline during the time frame scheduled messages have to be consumed. The broker does not attempt to redeliver the messages when consumers are back online.
**To Reproduce**
Steps to reproduce the behaviour:
1. Create a persistent topic with some partitions
2. Create a producer that produce messages after a short delay or at specific time. I used `deliverAfter` with 15 seconds delay.
3. Let the 15 seconds (or the scheduled time pass)
4. Bring up the consumers who consume messages from the topic. The consumers wont receive the messages.
**Expected behavior**
When the consumers are back online, the broker should attempt to push messages that are not delivered to them while they were offline
**Screenshots**
NA
**Desktop (please complete the following information):**
- OS: [e.g. iOS] MACOS
**Additional context**
Used Java
Used shared mode in consumers
Used Latest to consume from
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] vvijayv commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
vvijayv commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-931450610
Yes @shibd I think the subscription position solves this problem. I am closing this issue
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] vvijayv closed issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
vvijayv closed issue #12091:
URL: https://github.com/apache/pulsar/issues/12091
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] shibd commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
shibd commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-929740287
@vvijayv Hi, Does it solved your 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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] vvijayv commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
vvijayv commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-925750430
@shibd I will try this. But does it mean every time this consumer starts (restart/deployment/crash recovery) it will start consuming from the most earliest?
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] shibd commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
shibd commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-929740287
@vvijayv Hi, Does it solved your 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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] shibd commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
shibd commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-925805386
> @shibd I will try this. But does it mean every time this consumer starts (restart/deployment/crash recovery) it will start consuming from the most earliest?
No, If you use `subscribe api`, `SubscriptionInitialPosition` just take effect when first create subscribe. Pulsar can record(persistent) the position of subscribers.
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] shibd commented on issue #12091: Apache Pulsar delayed messages are not redelivered when consumers were offline during that time
Posted by GitBox <gi...@apache.org>.
shibd commented on issue #12091:
URL: https://github.com/apache/pulsar/issues/12091#issuecomment-925634472
@vvijayv Can you show your consumer configuration？Maybe you should use `SubscriptionInitialPosition.Earliest` when create consumer.
Example:
```java
Consumer<byte[]> subscribe = client.newConsumer()
.topic(topic)
.subscriptionName("my-subscribe")
.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
.subscribe();
```
--
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@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org