Panduan langkah demi langkah untuk belajar menggunakan pertanyaan versi Kafka

1. Pasang Kafka

• Muat turun dan pasang Apache Kafka pada pelayan anda.
• Ekstrak fail arkib Kafka.
• Tetapkan pembolehubah persekitaran KAFKA_HOME kepada direktori pemasangan 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. Mulakan ZooKeeper

ZooKeeper adalah tanggungan Kafka, jadi ia mesti dimulakan sebelum memulakan Kafka.

🎜Buka terminal baris arahan dan navigasi ke direktori $KAFKA_HOME/bin. 🎜🎜Jalankan arahan berikut untuk memulakan ZooKeeper: 🎜🎜

./kafka-version.sh

🎜🎜3 Mulakan pelayan Kafka 🎜🎜🎜🎜Buka terminal baris arahan dan navigasi ke direktori $KAFKA_HOME/bin. 🎜🎜Mulakan pelayan Kafka dengan menjalankan arahan berikut: 🎜🎜

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. Cipta topik 🎜🎜🎜🎜Topik ialah pengumpulan data yang logik dalam Kafka. 🎜🎜Untuk mencipta tema, buka terminal baris arahan dan navigasi ke direktori $KAFKA_HOME/bin. 🎜🎜Jalankan arahan berikut untuk mencipta topik: 🎜🎜rrreee🎜🎜5 Hantar mesej 🎜🎜🎜🎜Untuk menghantar mesej ke topik, buka terminal baris arahan dan navigasi ke $KAFKA_HOME/bin<.> direktori. 🎜🎜Jalankan arahan berikut untuk menghantar mesej: 🎜🎜rrreee🎜🎜6 Gunakan mesej 🎜🎜🎜🎜Untuk menggunakan mesej daripada topik, buka terminal baris arahan dan navigasi ke $KAFKA_HOME/bin direktori. 🎜🎜Jalankan arahan berikut untuk menggunakan mesej: 🎜🎜rrreee🎜🎜7. Versi pertanyaan 🎜🎜🎜🎜Untuk menanyakan versi pelayan Kafka, buka terminal baris arahan dan navigasi ke <kod>$KAFKA_HOME/bin kod> direktori. 🎜🎜Jalankan arahan berikut untuk menanyakan versi: 🎜🎜rrreee🎜🎜Contoh output🎜🎜rrreee</kod>

Atas ialah kandungan terperinci Panduan langkah demi langkah untuk belajar menggunakan pertanyaan versi Kafka. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!