Comment obtenir le numéro de version de Kafka

Comment afficher les informations sur la version de Kafka

Introduction

Apache Kafka est une plateforme de traitement de flux distribué qui vous permet de créer des pipelines de données en temps réel et de traiter de grandes quantités de données. Le débit élevé, la faible latence et la tolérance aux pannes de Kafka le rendent idéal pour créer des applications de données en temps réel.

Afficher les informations sur la version de Kafka

Pour afficher les informations sur la version de Kafka, vous pouvez utiliser les méthodes suivantes :

• Utiliser la ligne de commande

kafka-topics --version

• Utiliser l'API Java

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

Examp le

Vous trouverez ci-dessous un exemple d'affichage des informations sur la version de Kafka :

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

Le résultat montre que la version actuelle de Kafka est la 2.8.0.

Autres informations

En plus d'afficher les informations sur la version de Kafka, vous pouvez également utiliser la commande suivante pour afficher d'autres informations :

• Afficher l'ID du cluster Kafka

kafka-topics --describe --topic test

Les résultats de sortie contiennent les informations suivantes :

Cluster ID: N4lU-8KdQ5y2zUwDj82sAw

• Afficher la liste des sujets Kafka

kafka-topics --list

La sortie contient les informations suivantes :

test

• Afficher les détails du sujet Kafka

kafka-topics --describe --topic test

La sortie contient les informations suivantes :

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

Conclusion

Ceci L'article présente Comment vérifier les informations de version de Kafka et d'autres informations connexes. Ces informations sont très utiles pour gérer et maintenir les clusters Kafka.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!