-
Notifications
You must be signed in to change notification settings - Fork 3.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Subscribing on dedicated position #137
Labels
type/feature
The PR added a new feature or issue requested a new feature
Comments
merlimat
added
the
type/feature
The PR added a new feature or issue requested a new feature
label
Dec 3, 2016
merlimat
changed the title
[Feature Proposal] Subscribing on dedicated position
Subscribing on dedicated position
Dec 3, 2016
sijie
added a commit
to sijie/pulsar
that referenced
this issue
Mar 4, 2018
…nce required files into `target/python-instance` (apache#137) * Provide a copy task in runtime package phase to copy all python-instance required files into `target/python-instance` * cp api-python to target/python-instance/pulsar-function fix the licenses headers * Change `pulsar-function` to `pulsarfunction`
@DongbinNie Does subscriptionInitialPosition solve this for you? |
Closing for now since there's been no response. It looks like subscriptionInitialPosition solves the usecase |
hrsakai
pushed a commit
to hrsakai/pulsar
that referenced
this issue
Dec 10, 2020
…e#137) * Use the specified connection timeout when creating connections * Fixed compile and other errors
massakam
pushed a commit
to massakam/pulsar
that referenced
this issue
Feb 9, 2021
* feat: return MessageId as promise resolve at Producer#send * test: delete unused conf from Produce/Consume and validate MessageId test
hangc0276
pushed a commit
to hangc0276/pulsar
that referenced
this issue
May 26, 2021
…imes (apache#137) Fix IllegalArgumentException for KafkaConsumer#offsetsForTimes under kafka versions of 2.1.0 , 2.2.0 and 2.3.0
2 tasks
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Subscribing on other position instead of the last committed position on the first subscription.
[merlimat]
That would be only meaningful if the retention-time has been specified, otherwise the messages might have been already deleted. Also, what should the outcome be if subscribing to a position that is not available anymore?
[DongbinNie]
It may be a error or subscribing to the first available position.
[merlimat]
An option that is kind of similar is to subscribe and then rollback the subscription to X hours before.
[DongbinNie]
Yes, it can be achieved by this way.
The text was updated successfully, but these errors were encountered: