cmccabe opened a new pull request, #14399: URL: https://github.com/apache/kafka/pull/14399
KAFKA-15466: Add KIP-919 support for some admin APIs Add KIP-919 support for kafka-cluster.sh, kafka-features.sh, and kafka-metadata-quorum.sh. NetworkClient.java: don't hardcode "broker" in the log message about not being able to connect to a node. AdminClientConfig.java: add a constant for bootstrap.controllers. FinalizedVersionRange.java: make the constructor public for the sake of a junit test. AdminBootstrapAddresses.java: add this class to handle extracting bootstrap.servers or bootstrap.controllers from the config for KafkaAdminClient. KafkaAdminClient.java: allow the admin client to send a DESCRIBE_CLUSTER request to the kraft controllers, if bootstrap.controllers is configured. Extend Call so that it can handle bootstrap controllers. Note that not all admin client APIs currently handle bootstrap controllers. Some of them rely on APIs that the controller doesn't implement. Others will be implemented in follow-on changes. AdminMetadataManager.java: store the usingBootstrapControllers boolean. Generalize authException to encompass the concept of fatal exceptions in general. (For example, the fatal exception where we talked to the wrong node type.) Treat MismatchedEndpointTypeException and UnsupportedEndpointTypeException as fatal exceptions. BootstrapControllersIntegrationTest.java: add this integration test which verifies what happens when we use an admin client configured with bootstrap.servers against a local cluster. AuthHelper.scala: fix a bug in the initial KIP-919 change where the controllers were not setting the endpoint type correctly in their responses. CommandLineUtils.java: add some utilities for writing command-line utitilies that can take either --bootstrap-server or --bootstrap-controller. ClusterTool.java: add --bootstrap-controller support. MetadataQuorumCommand.java: add --bootstrap-controller support. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
