-
Notifications
You must be signed in to change notification settings - Fork 14.8k
KAFKA-19797: Added deliveryCompleteCount to writeState, ShareUpdate and ShareSnapshot schemas #20810
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
Conversation
AndrewJSchofield
left a comment
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.
Thanks for the new PR. Looks good to me.
| .setStateBatches(List.of(new WriteShareGroupStateRequestData.StateBatch() | ||
| .setFirstOffset(0) | ||
| .setLastOffset(10) | ||
| .setLastOffset(9) |
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.
Ideally, we should not be changing this value for the test, rather adjust the deliveryCompleteCount according to the original test. Same for other tests in this PR.
share-coordinator/src/main/resources/common/message/ShareSnapshotValue.json
Outdated
Show resolved
Hide resolved
share-coordinator/src/main/resources/common/message/ShareUpdateValue.json
Outdated
Show resolved
Hide resolved
share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java
Show resolved
Hide resolved
clients/src/main/resources/common/message/WriteShareGroupStateRequest.json
Outdated
Show resolved
Hide resolved
adixitconfluent
left a comment
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.
Thanks for the changes. LGTM.
#20820) This PR is part of [KIP-1226](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1226%3A+Introducing+Share+Partition+Lag+Persistence+and+Retrieval). In [KAFKA-19797](#20810), a new field deliveryCompleteCount was being sent by Share Partition to the persister. This PR introduces deliveryCompleteCount in ReadShareGroupStateSummary RPC so that it can later be used to calculate the share partition lag. Reviewers: Abhinav Dixit <[email protected]>, Sushant Mahajan <[email protected]>, Andrew Schofield <[email protected]>
This PR is part of
KIP-1226.
It introduces a new field called
deliveryCompleteCountinwriteShareGroupState RPC and
ShareUpdateandShareSnapshot. Theshare partition now maintains
inFlightTerminalCount(introducedhere) and it uses this
exact value to pass to the writeState request for
deliveryCompleteCount.Reviewers: Andrew Schofield [email protected], Abhinav Dixit
[email protected]