gharris1727 opened a new pull request, #12789: URL: https://github.com/apache/kafka/pull/12789
Signed-off-by: Greg Harris <[email protected]> https://issues.apache.org/jira/browse/KAFKA-13989 This method is used by the REST API in the `GET /connectors?expand=info,status` call. In cases where a connector has been created and later the connector plugin is removed, this generated a 500 error and hid the status of all other connectors. This is undesirable behavior as an error with the packaging of a single plugin severely impacts the operational visibility of the whole cluster. Instead, we should utilize the `UNKNOWN` enum value to indicate that it is currently unknown what type of connector that plugin is. This should prompt the user to further investigate the packaging issues with the plugin. In addition to fixing the reported issue, also simplify some call-sites with null-checks inside of the connectorTypeForConfig method. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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]
