Commande de requête de version Kafka : obtenez rapidement des informations pertinentes

Commande de requête de version Kafka

La commande de requête de version Kafka est utilisée pour interroger les informations de version du cluster Kafka. La syntaxe de la commande est la suivante :

kafka-topics --version

Un exemple de sortie de la commande est la suivante :

kafka-topics --version
kafka-topics version 2.7.0

Cet exemple de sortie indique que la version du cluster Kafka est 2.7.0.

Exemple de code concret

Ce qui suit est un exemple de code spécifique utilisant la commande de requête de la version Kafka :

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

L'exemple de code crée d'abord une instance AdminClient. Il interroge ensuite les informations de version du cluster Kafka à l'aide de la méthodescribeCluster() de l'instance AdminClient. Enfin, il imprime les informations de version du cluster Kafka.

Notes

• La commande de requête de version Kafka ne peut interroger que les informations de version du cluster Kafka. Il ne peut pas interroger les informations de version d'un seul nœud Kafka.
• La commande de requête de version Kafka ne peut interroger que les informations de version actuelle du cluster Kafka. Il ne peut pas interroger les informations de version historique du cluster Kafka.
• La commande de requête de version Kafka est une commande en lecture seule. Cela n'aura aucun impact sur le cluster Kafka.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!