Rumah > Java > javaTutorial > Panduan langkah demi langkah untuk belajar menggunakan pertanyaan versi Kafka

Panduan langkah demi langkah untuk belajar menggunakan pertanyaan versi Kafka

王林
Lepaskan: 2024-02-01 08:05:06
asal
1029 orang telah melayarinya

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
Salin selepas log masuk

3. 启动Kafka服务器

  • 打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令启动Kafka服务器:
./kafka-server-start.sh config/server.properties
Salin selepas log masuk

4. 创建主题

  • 主题是Kafka中数据的逻辑分组。
  • 要创建主题,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令创建主题:
./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1
Salin selepas log masuk

5. 发送消息

  • 要向主题发送消息,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令发送消息:
./kafka-console-producer.sh --topic my-topic --message "Hello, world!"
Salin selepas log masuk

6. 消费消息

  • 要消费主题的消息,请打开命令行终端并导航到$KAFKA_HOME/bin目录。
  • 运行以下命令消费消息:
./kafka-console-consumer.sh --topic my-topic --from-beginning
Salin selepas log masuk

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
Salin selepas log masuk
🎜🎜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
Salin selepas log masuk
🎜🎜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!

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan