Kafka バージョン クエリ コマンド: 関連情報を迅速に取得する

Kafka バージョン クエリ コマンド

Kafka バージョン クエリ コマンドは、Kafka クラスターのバージョン情報をクエリするために使用されます。このコマンドの構文は次のとおりです。

kafka-topics --version

このコマンドの出力例は次のとおりです。

kafka-topics --version
kafka-topics version 2.7.0

この出力例は、Kafka クラスターのバージョンが 2.7.0 であることを示しています。

具体的なコード例

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

このコード例では、最初に AdminClient インスタンスを作成します。 。次に、AdminClient インスタンスの descriptionCluster() メソッドを使用して、Kafka クラスターのバージョン情報をクエリします。最後に、Kafka クラスターのバージョン情報を出力します。

注

• Kafka バージョン クエリ コマンドは、Kafka クラスターのバージョン情報のみをクエリできます。単一の Kafka ノードのバージョン情報をクエリすることはできません。
• Kafka バージョン クエリ コマンドは、Kafka クラスターの現在のバージョン情報のみをクエリできます。 Kafka クラスターの履歴バージョン情報をクエリすることはできません。
• Kafka バージョン クエリ コマンドは読み取り専用のコマンドです。 Kafka クラスターには影響しません。

以上がKafka バージョン クエリ コマンド: 関連情報を迅速に取得するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。