Rumah  >  Artikel  >  Tutorial sistem  >  Panduan ringkas untuk memasang Kafka pada Linux

Panduan ringkas untuk memasang Kafka pada Linux

WBOY
WBOYasal
2024-02-01 08:32:051109semak imbas

Tajuk: Tutorial Pemasangan Linux Kafka: Bermula Dengan Pantas

Teks:

1. Kata Pengantar

Apache Kafka ialah sistem penerbitan yang diedarkan tinggi dan boleh melanggan data dengan jumlah yang besar. kependaman rendah dan kebolehpercayaan yang tinggi. Kafka digunakan secara meluas dalam pengumpulan log, analisis data, pemprosesan aliran dan bidang lain.

2. Persediaan pemasangan

  1. Sistem pengendalian: Linux (Ubuntu 18.04 atau lebih tinggi disyorkan)
  2. Java: JDK 8 atau lebih tinggi
  3. ZooKeeper: 3.4.14 atau lebih tinggi
  4. 3. Pasang ZooKeeper

Muat turun ZooKeeper: Muat turun pakej binari ZooKeeper dari laman web rasmi Apache.

    Unzip ZooKeeper: Nyahzip pakej binari yang dimuat turun ke direktori yang ditentukan.
  1. Konfigurasikan ZooKeeper: Cari fail conf/zoo.cfg dalam direktori ZooKeeper yang dinyahzip dan ubah suai konfigurasi berikut:
  • dataDir=/path/to/zookeeper/ data: Direktori data ZooKeeper

    conf/zoo.cfg 文件,并修改以下配置:

    • dataDir=/path/to/zookeeper/data:ZooKeeper 数据目录
    • clientPort=2181:ZooKeeper 客户端端口
  • 启动 ZooKeeper:运行以下命令启动 ZooKeeper:
  • bin/zkServer.sh start

    四、安装 Kafka

  1. 下载 Kafka:从 Apache 官网下载 Kafka 二进制包。
  2. 解压 Kafka:将下载的二进制包解压到指定目录。
  3. 配置 Kafka:在解压后的 Kafka 目录下找到 config/server.properties 文件,并修改以下配置:

    • broker.id=0:Kafka 代理 ID
    • zookeeper.connect=localhost:2181:ZooKeeper 连接地址
    • log.dirs=/path/to/kafka/logsclientPort=2181: Port klien ZooKeeper
  4. Mulakan ZooKeeper: Jalankan arahan berikut untuk memulakan ZooKeeper:
bin/kafka-server-start.sh config/server.properties

Installation Kafe

    Muat turun Kafka: Muat turun pakej binari Kafka dari laman web rasmi Apache.
  1. Ekstrak Kafka: Ekstrak pakej binari yang dimuat turun ke direktori yang ditentukan.
  1. Konfigurasikan Kafka: Cari fail config/server.properties dalam direktori Kafka yang dinyahmampat, dan ubah suai konfigurasi berikut:
    broker.id=0 : ID broker Kafka

    zookeeper.connect=localhost:2181: Alamat sambungan ZooKeeper

    log.dirs=/path/to/kafka/logs: Direktori log Kafka
    Mulakan Kafka: Jalankan arahan berikut untuk memulakan Kafka:

    bin/kafka-console-producer.sh --topic my-topic

    5. Cipta topik
    Buka alat baris arahan Kafka: Jalankan arahan berikut untuk membuka alat baris arahan Kafka
      :
    1. rr alat baris arahan
    2. Cipta topik: Dalam Kafka Masukkan arahan berikut dalam alat baris arahan untuk mencipta topik:

    create my-topic --replication-factor 1 --partitions 1
    6. Hantar mesej

    1. Masukkan arahan berikut dalam alat baris arahan Kafka untuk menghantar mesej:
      send my-topic hello world
    1. 7. Terima mesej

    Buka alat baris arahan A Kafka yang lain: Jalankan arahan berikut untuk membuka alat baris arahan Kafka yang lain:

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

    🎜Terima mesej: Kaf arahan akan dipaparkan dalam mesej alat garisan. 🎜🎜🎜🎜 8. Hentikan Kafka 🎜🎜🎜🎜Jalankan arahan berikut untuk menghentikan Kafka: 🎜🎜
    bin/kafka-server-stop.sh
    🎜🎜Jalankan arahan berikut untuk menghentikan ZooKeeper: 🎜🎜9rreee 🎜Melalui langkah di atas, anda telah berjaya memasang Linux pada Linux Kafka dipasang pada. Kini anda boleh mula menggunakan Kafka untuk memproses data anda. 🎜

Atas ialah kandungan terperinci Panduan ringkas untuk memasang Kafka pada Linux. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Kenyataan:
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