-
Notifications
You must be signed in to change notification settings - Fork 14.1k
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-18633: Remove errorUnavailableEndpoints from handleTopicMetadataRequest #18692
base: trunk
Are you sure you want to change the base?
Conversation
@@ -60,42 +60,25 @@ class KRaftMetadataCache( | |||
|
|||
// This method is the main hotspot when it comes to the performance of metadata requests, | |||
// we should be careful about adding additional logic here. | |||
// filterUnavailableEndpoints exists to support v0 MetadataResponses | |||
private def maybeFilterAliveReplicas(image: MetadataImage, |
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 method has one-line only, so maybe we can inline this method?
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.
Sounds fair:)
Done.
Let's please not merge this for now. We're considering the possibility of restoring the older metadata versions since that change breaks all released versions of kafka-python. |
yes, let me add link to the jira (https://issues.apache.org/jira/browse/KAFKA-18648) |
Description
Remove
errorUnavailableEndpoints
, this is no longer required as the min version of MetadataRequest is v4 so the flag is always false now.Jira: https://issues.apache.org/jira/browse/KAFKA-18633
Committer Checklist (excluded from commit message)