So erhalten Sie die Kafka-Versionsnummer

So zeigen Sie Kafka-Versionsinformationen an

Einführung

Apache Kafka ist eine verteilte Stream-Verarbeitungsplattform, mit der Sie Echtzeit-Datenpipelines erstellen und große Datenmengen verarbeiten können. Der hohe Durchsatz, die geringe Latenz und die Fehlertoleranz von Kafka machen es ideal für die Erstellung von Echtzeit-Datenanwendungen.

Informationen zur Kafka-Version anzeigen

Um Kafka-Versionsinformationen anzuzeigen, können Sie die folgenden Methoden verwenden:

• Befehlszeile verwenden

kafka-topics --version

• Java-API verwenden

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

Beispiel

Unten sehen Sie ein Beispiel für die Anzeige von Kafka-Versionsinformationen:

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

Die Ausgabe zeigt, dass die aktuelle Kafka-Version 2.8.0 ist.

Andere Informationen

Zusätzlich zum Anzeigen der Kafka-Versionsinformationen können Sie auch den folgenden Befehl verwenden, um andere Informationen anzuzeigen:

• Kafka-Cluster-ID anzeigen

kafka-topics --describe --topic test

Die Ausgabeergebnisse enthalten die folgenden Informationen:

Cluster ID: N4lU-8KdQ5y2zUwDj82sAw

• Kafka-Themenliste anzeigen

kafka-topics --list

Die Ausgabe enthält die folgenden Informationen:

test

• Kafka-Themendetails anzeigen

kafka-topics --describe --topic test

Die Ausgabe enthält die folgenden Informationen:

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

Fazit

Das In diesem Artikel wird vorgestellt, wie Sie Kafka-Versionsinformationen und andere verwandte Informationen überprüfen. Diese Informationen sind für die Verwaltung und Wartung von Kafka-Clustern sehr nützlich.

Das obige ist der detaillierte Inhalt vonSo erhalten Sie die Kafka-Versionsnummer. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!