Un guide étape par étape pour apprendre à utiliser les requêtes de version Kafka

1. Installez Kafka

• Téléchargez et installez Apache Kafka sur votre serveur.
• Extraire les fichiers d'archives Kafka.
• Définissez la variable d'environnement KAFKA_HOME sur le répertoire d'installation de Kafka. KAFKA_HOME为Kafka安装目录。

2. 启动ZooKeeper

• ZooKeeper是Kafka的依赖项，因此在启动Kafka之前必须先启动它。
• 打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令启动ZooKeeper：

./zookeeper-server-start.sh config/zookeeper.properties

3. 启动Kafka服务器

• 打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令启动Kafka服务器：

./kafka-server-start.sh config/server.properties

4. 创建主题

• 主题是Kafka中数据的逻辑分组。
• 要创建主题，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令创建主题：

./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1

5. 发送消息

• 要向主题发送消息，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令发送消息：

./kafka-console-producer.sh --topic my-topic --message "Hello, world!"

6. 消费消息

• 要消费主题的消息，请打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令消费消息：

./kafka-console-consumer.sh --topic my-topic --from-beginning

7. 查询版本

• 要查询Kafka服务器的版本，请打开命令行终端并导航到$KAFKA_HOME/bin
• 2. Démarrez ZooKeeper

ZooKeeper est une dépendance de Kafka, il doit donc être démarré avant de démarrer Kafka.

🎜Ouvrez un terminal de ligne de commande et accédez au répertoire $KAFKA_HOME/bin. 🎜🎜Exécutez la commande suivante pour démarrer ZooKeeper : 🎜🎜

./kafka-version.sh

🎜🎜3. Démarrez le serveur Kafka 🎜🎜🎜🎜Ouvrez un terminal de ligne de commande et accédez au répertoire $KAFKA_HOME/bin. 🎜🎜Démarrez le serveur Kafka en exécutant la commande suivante : 🎜🎜

kafka-version.sh:
 version: 2.8.0
 kafka-version: 2.8.0
 kafka-storage: 2.8.0
 kafka-clients: 2.8.0
 kafka-streams: 2.8.0
 kafka-connect: 2.8.0
 kafka-admin: 2.8.0
 kafka-tools: 2.8.0

🎜🎜4. Créez un sujet 🎜🎜🎜🎜Un sujet est un regroupement logique de données dans Kafka. 🎜🎜Pour créer un thème, ouvrez un terminal de ligne de commande et accédez au répertoire $KAFKA_HOME/bin. 🎜🎜Exécutez la commande suivante pour créer un sujet : 🎜🎜rrreee🎜🎜5. Envoyer un message 🎜🎜🎜🎜Pour envoyer un message au sujet, ouvrez un terminal de ligne de commande et accédez au $KAFKA_HOME/bin<.> répertoire. 🎜🎜Exécutez la commande suivante pour envoyer un message : 🎜🎜rrreee🎜🎜6. Consommer des messages 🎜🎜🎜🎜Pour consommer des messages d'un sujet, ouvrez un terminal de ligne de commande et accédez au <code>$KAFKA_HOME/bin répertoire. 🎜🎜Exécutez la commande suivante pour consommer les messages : 🎜🎜rrreee🎜🎜7. Requête de version 🎜🎜🎜🎜Pour interroger la version du serveur Kafka, ouvrez un terminal de ligne de commande et accédez au $KAFKA_HOME/bin code> répertoire. 🎜🎜Exécutez la commande suivante pour interroger la version : 🎜🎜rrreee🎜🎜Exemple de sortie🎜🎜rrreee

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!