Open
Description
Search before asking
- I searched in the issues and found nothing similar.
What issue do you find in Pulsar docs?
https://pulsar.apache.org/docs/next/client-libraries-tableviews/
There are two methods for consuming table views:
// Register listeners for all existing and incoming messages
tv.forEachAndListen((key, value) -> /*operations on all existing and incoming messages*/)
// Register actions for all existing messages
tv.forEach((key, value) -> /*operations on all existing messages*/)
The docs do not specify if tombstone messages are propagated. I believe that forEach will not show them, but totally unsure about forEachAndListen
What is your suggestion?
Specify TombStone behaviour
Any reference?
No response
Are you willing to submit a PR?
- I'm willing to submit a PR!