Skip to content

KAFKA-16526; Add quorum state v1#15781

Closed
jsancio wants to merge 56 commits intoapache:trunkfrom
jsancio:kafka-16526-quorum-state
Closed

KAFKA-16526; Add quorum state v1#15781
jsancio wants to merge 56 commits intoapache:trunkfrom
jsancio:kafka-16526-quorum-state

Conversation

@jsancio
Copy link
Copy Markdown
Member

@jsancio jsancio commented Apr 22, 2024

DRAFT - needs #15671

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

jsancio added 30 commits January 30, 2024 16:28
@jsancio
KAFKA-16207; Add KRaftVersionRecord and VotersRecord
dd84479
@jsancio
Some observation while reviewing the KIP and implementation
87a43c6
@jsancio
Fix compilation errors
c9de8a1
@jsancio
KAFKA-16207; Match KIP schema
54b164e
@jsancio
KAFKA-16207; Implement VoterSet and VoterSetHistory
04fcf4c
@jsancio
KAFKA-16207; Add impl for internal log listener
702e739
@jsancio
KAFKA-16207; Add historical kraft version
fae8b84
@jsancio
KAFKA-16207; Import refactor to delay voter address evaluation
25d9dfd
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
b3e65bd 
…al-listener
@jsancio
KAFKA-16207; Fix core and metadata after raft changes
9a6b4c2
@jsancio
KAFKA-16207; More voter parsing clean ups
24661b1
@jsancio
KAFKA-16207; User the voter set from the config or log
cd3277c
@jsancio
KAFKA-16207; Return node id before calling initialize
f3a0fcd
@jsancio
KAFKA-16207; Add a builder for record snaapshot writer
08e1831
@jsancio
KAFKA-16207; Include kraft.version and voter set in the snapshots
89ac698
@jsancio
KAFKA-16207; Use SupportedVersionRange
2889b42
@jsancio
KAFKA-16207; Fix version range documentation
1188b94
@jsancio
KAFKA-16207; Snapshots should return control records
92909fb
@jsancio
KAFKA-16207; Document internal listener invariant
dd28ef4
@jsancio
KAFKA-16207; Update some of the documentation
deb7920
@jsancio
KAFKA-16207; Fix cluster snapshot test
0db1a06
@jsancio
KAFKA-16207; Implement truncating and prefix trimming the internal li…
ab1886a 
…stener
@jsancio
KAFKA-16207; Finish documenting all of the type and methods
a962188
@jsancio
KAFKA-16207; Implement some of the unittest
1829e06
@jsancio
KAFKA-16207; Add 2 more test suites
a108e9c
@jsancio
KAFKA-16207; Make the control batch buffer configurable
795858f
@jsancio
KAFKA-16207; Add tests for snapshot builder
a79660e
@jsancio
KAFKA-16207; Add test for internal partition listener
625aabd
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
855a13e 
…al-listener
@jsancio
KAFKA-16526; Add quorum state v1
ee21de1
@jsancio jsancio added kraft KIP-853 KRaft Controller Membership Changes labels Apr 22, 2024
jsancio added 26 commits April 22, 2024 10:14
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
629c7da 
…al-listener
@jsancio
Merge branch 'kafka-16207-internal-listener' into kafka-16526-quorum-…
027260b 
…state
@jsancio
KAFKA-16526; Fix tests
c2972a8
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
bc26f59 
…al-listener
@jsancio
Merge branch 'kafka-16207-internal-listener' into kafka-16526-quorum-…
d77b243 
…state
@jsancio
KAFKA-16526; Fix impl for file backed quorum store
3f77416
@jsancio
KAFKA-16526; Add tests for election state
b1af427
@jsancio
KAFKA-16207; Use directory id instead of uuid
b6fc7f6
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
742c969 
…al-listener
@jsancio
KAFKA-16207; Many fixes and improvements
e55564d
@jsancio
KAFKA-16207; Rename PartitionListener
de19062
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
66c3793 
…al-listener
@jsancio
Merge branch 'kafka-16207-internal-listener' into kafka-16526-quorum-…
d802eba 
…state
@jsancio
KAFKA-16526; Add a few more tests
5e06e79
@jsancio
KAFKA-16526; Use directory id instead of uuid
81f433e
@jsancio
KAFKA-16526; Add current-vote-directory-id metrics
4883442
@jsancio
KAFKA-16526; Remove the new metrics
534023d
@jsancio
KAFKA-16526; Add voted directory id test for quorum state
c438c15
@jsancio
KAFKA-16207; Review feedback changes
c821a83
@jsancio
KAFKA-16207; Better validate the control records in the accumulator
c2a7a9a
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16207-intern…
d1c17e0 
…al-listener
@jsancio
Merge branch 'kafka-16207-internal-listener' into kafka-16526-quorum-…
76ffca3 
…state
@jsancio
KAFKA-16526; Use voter key
96881f9
@jsancio
KAFKA-16526; Corrupted quorum state should fail the process
9188d27
@jsancio
KAFKA-16526; User voter key in candidate state
4331fa7
@jsancio
Merge remote-tracking branch 'upstream/trunk' into kafka-16526-quorum…
8d0360f 
…-state
@jsancio jsancio closed this May 4, 2024
@jsancio jsancio deleted the kafka-16526-quorum-state branch May 4, 2024 20:50
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

KIP-853 KRaft Controller Membership Changes kraft

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@jsancio