Home  >  Article  >  Java  >  Kafka version query command: quickly obtain relevant information

Kafka version query command: quickly obtain relevant information

王林
王林Original
2024-01-31 15:03:061262browse

Kafka version query command: quickly obtain relevant information

Kafka version query command

The Kafka version query command is used to query the version information of the Kafka cluster. The syntax of this command is as follows:

kafka-topics --version

The output example of this command is as follows:

kafka-topics --version
kafka-topics version 2.7.0

This output example indicates that the version of the Kafka cluster is 2.7.0.

Specific code example

The following is a specific code example using the Kafka version query command:

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.KafkaAdminClient;

public class KafkaVersionQuery {

    public static void main(String[] args) {
        // Create an AdminClient instance
        AdminClient adminClient = KafkaAdminClient.create(KafkaProperties.get());

        // Query the Kafka cluster version
        String version = adminClient.describeCluster().version().toString();

        // Print the Kafka cluster version
        System.out.println("Kafka cluster version: " + version);

        // Close the AdminClient instance
        adminClient.close();
    }
}

This code example first creates an AdminClient instance . It then queries the version information of the Kafka cluster using the describeCluster() method of the AdminClient instance. Finally, it prints the version information of the Kafka cluster.

Note

  • The Kafka version query command can only query the version information of the Kafka cluster. It cannot query the version information of a single Kafka node.
  • The Kafka version query command can only query the current version information of the Kafka cluster. It cannot query the historical version information of the Kafka cluster.
  • The Kafka version query command is a read-only command. It will not cause any impact on the Kafka cluster.

The above is the detailed content of Kafka version query command: quickly obtain relevant information. For more information, please follow other related articles on the PHP Chinese website!

Statement:
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn