Perintah pertanyaan versi Kafka: cepat dapatkan maklumat yang berkaitan

Perintah pertanyaan versi Kafka

Perintah pertanyaan versi Kafka digunakan untuk menanyakan maklumat versi gugusan Kafka. Sintaks arahan adalah seperti berikut:

kafka-topics --version

Contoh output arahan adalah seperti berikut:

kafka-topics --version
kafka-topics version 2.7.0

Contoh output ini menunjukkan bahawa versi gugusan Kafka ialah 2.7.0.

Contoh kod konkrit

Berikut ialah contoh kod khusus menggunakan arahan pertanyaan versi 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();
    }
}

Contoh kod mula-mula mencipta contoh AdminClient. Ia kemudian menanyakan maklumat versi gugusan Kafka menggunakan kaedah describeCluster() bagi contoh AdminClient. Akhirnya, ia mencetak maklumat versi gugusan Kafka.

Nota

• Arahan pertanyaan versi Kafka hanya boleh menanyakan maklumat versi gugusan Kafka. Ia tidak boleh menanyakan maklumat versi satu nod Kafka.
• Arahan pertanyaan versi Kafka hanya boleh menanyakan maklumat versi semasa gugusan Kafka. Ia tidak boleh menanyakan maklumat versi sejarah gugusan Kafka.
• Arahan pertanyaan versi Kafka ialah perintah baca sahaja. Ia tidak akan menyebabkan sebarang impak kepada gugusan Kafka.

Atas ialah kandungan terperinci Perintah pertanyaan versi Kafka: cepat dapatkan maklumat yang berkaitan. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!