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

Kafka version query command: quickly obtain relevant information

王林
Release: 2024-01-31 15:03:06
Original
1317 people have browsed it

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
Copy after login

The output example of this command is as follows:

kafka-topics --version
kafka-topics version 2.7.0
Copy after login

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();
    }
}
Copy after login

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!

source:php.cn
Statement of this Website
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
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template