kafka-broker-api-versions

From wikieduonline
Jump to navigation Jump to search


kafka-broker-api-versions
kafka-broker-api-versions --bootstrap-server localhost:9092
kafka-broker-api-versions --bootstrap-server localhost
Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: localhost
.../...

kafka-broker-api-versions --version
3.7.0


kafka-broker-api-versions
This tool helps to retrieve broker version information.
Option                                 Description
------                                 -----------
--bootstrap-server <String: server(s)  REQUIRED: The server to connect to.
  to use for bootstrapping>
--command-config <String: command      A property file containing configs to
  config property file>                  be passed to Admin Client.
--help                                 Print usage information.
--version                              Display Kafka version.

Errors[edit]

kafka-broker-api-versions --bootstrap-server localhost:9092

[2024-03-20 20:11:16,481] WARN [LegacyAdminClient clientId=admin-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient)
[2024-03-20 20:11:16,481] WARN [LegacyAdminClient clientId=admin-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
Exception in thread "main" java.lang.RuntimeException: Request METADATA failed on brokers List(localhost:9092 (id: -1 rack: null))
	at kafka.admin.BrokerApiVersionsCommand$AdminClient.sendAnyNode(BrokerApiVersionsCommand.scala:155)
	at kafka.admin.BrokerApiVersionsCommand$AdminClient.findAllBrokers(BrokerApiVersionsCommand.scala:178)
	at kafka.admin.BrokerApiVersionsCommand$AdminClient.awaitBrokers(BrokerApiVersionsCommand.scala:170)
	at kafka.admin.BrokerApiVersionsCommand$.execute(BrokerApiVersionsCommand.scala:60)
	at kafka.admin.BrokerApiVersionsCommand$.main(BrokerApiVersionsCommand.scala:54)
	at kafka.admin.BrokerApiVersionsCommand.main(BrokerApiVersionsCommand.scala)

See also[edit]

Advertising: