mingyen066 opened a new pull request, #22978: URL: https://github.com/apache/kafka/pull/22978
Follow-up to https://github.com/apache/kafka/pull/20598#discussion_r3667202261 `describeFeatures()` now returns an `InternalDescribeFeaturesResult` carrying a `nodeApiVersions` future, but `handleFailure` only completes the `FeatureMetadata` future. When the ApiVersions request fails (for example on timeout), `nodeApiVersions()` is never completed and callers waiting on it hang indefinitely. The error-code branch in `handleResponse` already completes both. Extended the existing `testDescribeFeatures*` tests to assert both futures. `testDescribeFeaturesWithNodeFailure` is the one that covers `handleFailure`; it hangs until the class-level timeout without this fix. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
