如何取得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中文網其他相關文章！