You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
// 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!
The text was updated successfully, but these errors were encountered:
Search before asking
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:
The docs do not specify if tombstone messages are propagated. I believe that
forEach
will not show them, but totally unsure aboutforEachAndListen
What is your suggestion?
Specify TombStone behaviour
Any reference?
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: