-
Notifications
You must be signed in to change notification settings - Fork 14k
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
KAFKA-18039: Test all versions of quorum responses in RequestResponseTest #17873
base: trunk
Are you sure you want to change the base?
Conversation
- Modified createDescribeQuorumResponse, createEndQuorumEpochResponse, and createBeginQuorumEpochResponse methods to accept a version parameter. - Adjusted logic to set properties based on the version, ensuring compatibility with different response versions. - Added node endpoint handling for EndQuorumEpochResponse and BeginQuorumEpochResponse based on version checks.
@ahuang98 Hi, This PR is ready, could you please take a look, thanks! |
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.
lgtm! thanks for the quick changes
.setCurrentVoters(singletonList(replicaState)) | ||
.setObservers(singletonList(replicaState)); | ||
DescribeQuorumResponseData.TopicData topicData = new DescribeQuorumResponseData.TopicData() | ||
.setTopicName("topic1") |
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.
nit: should we just make this __cluster_metadata
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.
@ahuang98 Thanks, fixed
… metadata topic name
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.
Following should support accepting
version
as they have more than one versionRelated links
Committer Checklist (excluded from commit message)