Kafkaのバージョン番号を取得する方法

Kafka のバージョン情報を確認する方法

はじめに

Apache Kafka は分散ストリーム処理ですリアルタイム データ パイプラインを構築し、大量のデータを処理できるプラットフォーム。 Kafka の高スループット、低遅延、耐障害性により、リアルタイム データ アプリケーションの構築に最適です。

Kafka バージョン情報の表示

Kafka バージョン情報を表示するには、次の方法を使用できます:

• コマンド ラインを使用する

kafka-topics --version

• #Java API の使用##

  Properties properties = new Properties();
  properties.put("bootstrap.servers", "localhost:9092");
  
  KafkaAdminClient adminClient = KafkaAdminClient.create(properties);
  DescribeClusterResult result = adminClient.describeCluster();
  
  System.out.println("Kafka version: " + result.clusterId());

#例

次のKafka のバージョン情報を表示する例:

$ kafka-topics --version
kafka_2.12-2.8.0

出力は、現在の Kafka バージョンが 2.8.0 であることを示しています。

その他の情報

Kafka バージョン情報を表示することに加えて、次のコマンドを使用して他の情報を表示することもできます:

Kafka クラスター ID を表示します
• #

  kafka-topics --describe --topic test

  出力には次の情報が含まれます:

Cluster ID: N4lU-8KdQ5y2zUwDj82sAw

#Kafka トピック リストを表示

#

kafka-topics --list

• 出力結果には次の情報が含まれます:

  test

Kafka トピックの詳細の表示

kafka-topics --describe --topic test

• 出力結果には次の情報が含まれます。次の情報:

  Topic: test
  PartitionCount: 1
  ReplicationFactor: 1
  Configs:
      cleanup.policy=delete
      compression.type=producer
      follower.replication.throttled.replicas=
      leader.replication.throttled.replicas=
      max.message.bytes=1000000
      message.downconversion.enable=true
      message.format.version=2.8
      min.cleanable.dirty.bytes=52428800
      min.compaction.lag.ms=0
      min.insync.replicas=1
      preallocate=false
      retention.bytes=-1
      retention.ms=-1
      segment.bytes=1073741824
      segment.index.bytes=10485760
      segment.jitter.ms=0
      segment.ms=604800000

  結論
  この記事では、Kafka のバージョン情報およびその他の関連情報を表示する方法を紹介します。この情報は、Kafka クラスターの管理と保守に非常に役立ちます。

  以上がKafkaのバージョン番号を取得する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。