-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Subscription: implement IoTConsensus-based subscription #17238
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
Merged
jt2594838
merged 64 commits into
apache:master
from
DanielWang2035:consensus-subscription
Jun 9, 2026
Merged
Changes from 1 commit
Commits
Show all changes
64 commits
Select commit
Hold shift + click to select a range
6252d13
Subscription: implement IoTConsensus-based subscription
DanielWang2035 36e3491
fix some issues
DanielWang2035 8d2ba7d
support seek and WAL retention
DanielWang2035 0e3b768
refactor
DanielWang2035 b3c39ff
Merge branch 'master' into consensus-subscription
DanielWang2035 932617e
refactor
DanielWang2035 8ba8165
fix
DanielWang2035 658f0a6
fix
DanielWang2035 ae9d722
fix part1
DanielWang2035 e3eedcf
fix part2
DanielWang2035 a861944
fix part3.1
DanielWang2035 5a4f7da
fix part3.2
DanielWang2035 8e53fc6
fix part4.1
DanielWang2035 32e6d11
merge master
DanielWang2035 2794d31
fix seek
DanielWang2035 6f98bd6
fix test
DanielWang2035 0fbc551
refactor thread model
DanielWang2035 774427b
add time based retention and column pattern
DanielWang2035 db92a35
clean old epoch
DanielWang2035 6e86c0b
add config for consensus subscription
DanielWang2035 8b275b1
fix comments
DanielWang2035 c29f262
merge master
DanielWang2035 cd8edaf
remove some tests
DanielWang2035 db22cf3
add check for non-IoTConsensus
DanielWang2035 ff5ff9c
refactor IT
DanielWang2035 f14cc8f
Merge branch 'master' into consensus-subscription
DanielWang2035 d92f451
fix review
DanielWang2035 0447dd1
fix UT & IT
DanielWang2035 9a47d5d
Merge branch 'master' into consensus-subscription
DanielWang2035 bae094f
fix comments
DanielWang2035 8263b0d
fix comments
DanielWang2035 ef6c909
remove writerEpoch field & unify the order of fields
DanielWang2035 80364f3
merge master
DanielWang2035 39467c0
fix test
DanielWang2035 a4756cf
spotless
DanielWang2035 807ab3a
fix IT
DanielWang2035 b69a7b5
remove special logic of CONTINUOUS_SAME_SEARCH_INDEX_SEPARATOR_NODE
DanielWang2035 0fbba3f
make partial commit responses explicit
DanielWang2035 c70bacc
keep processor-buffered messages pinned until release
DanielWang2035 77961df
make manual close safe with processor buffers
DanielWang2035 43cd5be
tolerate non-owning providers during consensus seek
DanielWang2035 ada74c9
Merge branch 'master' into consensus-subscription
DanielWang2035 739e308
fix UT
DanielWang2035 3d2dbf7
fix IT
DanielWang2035 de3d167
refactor progress persist
DanielWang2035 ad1a609
merge master
DanielWang2035 94faf00
spotless
DanielWang2035 38fcc6b
fix some issues
DanielWang2035 f393fa2
fix some issues
DanielWang2035 c616e59
extract some logic into broker interface
DanielWang2035 f42f19e
fix ColumnAlignProcessor
DanielWang2035 f361474
simplify some concepts
DanielWang2035 9da9880
fix some naming and comments
DanielWang2035 b6efcb1
fix some issues
DanielWang2035 4968e1d
fix some issues
DanielWang2035 ef45738
Merge branch 'master' into consensus-subscription
DanielWang2035 3103685
rename
DanielWang2035 410aa89
Avoided persisting writer.meta on every successful write & Grouped ad…
DanielWang2035 2cda962
rename
DanielWang2035 becf7f3
fix
DanielWang2035 566ea99
fix
DanielWang2035 5ea4280
Merge upstream master into consensus-subscription
VGalaxies aa6810e
Refine subscription broker routing
VGalaxies 75bacb1
Fix consensus subscription replay dedup
VGalaxies File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This module overrides the example parent’s compiler level (example/pom.xml sets source/target=8) to Java 11. That can break building examples under the project’s expected Java version and makes the module inconsistent with other examples. Prefer inheriting the parent compiler settings (or updating the parent if the whole examples tree should move to 11) instead of overriding in this module.