Kafka バージョン クエリを解析するコマンド

1. Kafka バージョン クエリ コマンドの概要

Kafka バージョン クエリ コマンドは、Kafka クラスターのバージョン情報をクエリするために使用されます。ユーザーはクラスタの稼働状況を把握し、バージョンアップなどの操作を行うことができます。 Kafka には、コマンド ライン ツール、API、JMX の使用など、バージョン情報をクエリするための複数の方法が用意されています。

2. バージョンを照会するコマンド ライン ツール

Kafka は、クラスターのバージョン情報を照会するための kafka-version.sh という名前のコマンド ライン ツールを提供します。このツールは、Kafka インストール ディレクトリの bin ディレクトリにあり、次のコマンドを使用して実行できます。

./kafka-version.sh

このコマンドは、Kafka バージョン番号、ビルド日、バージョン情報など、現在の Kafka クラスターのバージョン情報を出力します。リビジョン番号など

3. API クエリ バージョン

Kafka は、バージョン情報をクエリするための API も提供します。次のコード サンプルを使用して、バージョン情報をクエリできます。

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

public class KafkaVersionQuery {

  public static void main(String[] args) {
    // 创建AdminClient实例
    AdminClient adminClient = AdminClient.create();

    // 查询集群版本信息
    DescribeClusterResult describeClusterResult = adminClient.describeCluster();

    // 获取集群版本号
    String clusterVersion = describeClusterResult.clusterId().version();

    // 打印集群版本号
    System.out.println("Cluster version: " + clusterVersion);

    // 关闭AdminClient实例
    adminClient.close();
  }
}

このコード サンプルでは、​​AdminClient を使用してクラスターのバージョン情報をクエリし、コンソールに出力します。

4. JMX クエリ バージョン

Kafka は、バージョン情報をクエリするための JMX インターフェイスも提供します。次のコード例を使用して、バージョン情報をクエリできます。

import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import java.lang.management.ManagementFactory;

public class KafkaVersionQuery {

  public static void main(String[] args) {
    // 获取MBeanServerConnection实例
    MBeanServerConnection mBeanServerConnection = ManagementFactory.getPlatformMBeanServer();

    // 创建ObjectName实例
    ObjectName objectName = new ObjectName("kafka.server:type=Broker,name=0");

    // 获取Kafka版本号
    String kafkaVersion = (String) mBeanServerConnection.getAttribute(objectName, "version");

    // 打印Kafka版本号
    System.out.println("Kafka version: " + kafkaVersion);
  }
}

このコード例では、MBeanServerConnection を使用して Kafka バージョン情報をクエリし、コンソールに出力します。

5. 概要

Kafka は、コマンド ライン ツール、API、JMX の使用など、バージョン情報をクエリするさまざまな方法を提供します。ユーザーは、自分のニーズに応じて、バージョン情報を照会するための適切な方法を選択できます。

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