Cara Memasang Apache Kafka di Centos/RHEL 7

Apache Kafka adalah enjin pemesejan yang kuat, yang digunakan secara meluas Data besar projek dan Analisis data kitaran hidup. Ia adalah platform sumber terbuka untuk membina saluran paip streaming data masa nyata. Ia adalah platform subscribe penerbitan yang diedarkan dengan kebolehpercayaan, skalabiliti, dan ketahanan.

Kita boleh Kafka sebagai mandiri atau sebagai kelompok. Kafka menyimpan data streaming, dan ia boleh dikategorikan sebagai Topik. The Topik akan mempunyai sebilangan partisi supaya ia dapat mengendalikan jumlah data sewenang -wenangnya. Juga, kita boleh mempunyai banyak replika untuk toleransi kesalahan seperti yang kita ada HDFS. Dalam kluster Kafka, broker adalah komponen yang menyimpan data yang diterbitkan.

Zookeeper adalah perkhidmatan wajib untuk menjalankan a Kafka cluster, seperti yang digunakan untuk menguruskan penyelarasan broker Kafka. Zookeeper memainkan peranan utama antara pengeluar dan pengguna di mana ia bertanggungjawab untuk mengekalkan keadaan semua broker.

Dalam artikel ini, kami akan menerangkan cara memasang Apache Kafka dalam satu nod tunggal Centos 7 atau RHEL 7.

Memasang Apache Kafka di CentOS 7

1. Pertama, anda perlu memasang Java pada sistem anda untuk dijalankan Apache Kafka tanpa sebarang kesilapan. Oleh itu, pasang versi lalai yang tersedia Java Menggunakan arahan yum berikut dan sahkan Java versi seperti yang ditunjukkan.

# yum -y pasang java -1.8.0 -openjdk # java -version 

2. Seterusnya, muat turun versi stabil terbaru Apache Kafka dari laman web rasmi atau gunakan arahan wget berikut untuk memuat turunnya secara langsung dan mengeluarkannya.

# wget https: // cermin.Estointernet.In/Apache/Kafka/2.7.0/Kafka_2.13-2.7.0.tgz # tar -xzf kafka_2.13-2.7.0.TGZ 

3. Buat pautan simbolik untuk Kafka pakej, kemudian tambahkan laluan persekitaran Kafka ke .BASH_PROFILE fail dan kemudian memulakannya seperti yang ditunjukkan.

# ln -s kafka_2.13-2.7.0 Kafka # echo "Path Export = $ Path:/root/kafka_2.13-2.7.0/bin ">> ~/.bash_profile # sumber ~/.BASH_PROFILE 

4. Seterusnya, mulakan Penjaga zoo, yang datang terbina dalam dengan Kafka pakej. Oleh kerana ia adalah kluster nod tunggal, anda boleh memulakan zookeeper dengan sifat lalai.

# Zookeeper-Server-Start.sh -daemon/root/kafka/config/zookeeper.sifat 

5. Mengesahkan sama ada zookeeper boleh diakses atau tidak dengan mudah telnet ke Penjaga zoo pelabuhan 2181.

# Telnet Localhost 2181 

6. Mulakan Kafka dengan sifat lalai.

# Kafka-server-start.sh -daemon/root/kafka/config/pelayan.sifat 

7. Mengesahkan sama ada Kafka boleh diakses atau tidak dengan hanya telnet ke port kafka 9092

# Telnet Localhost 9092 

8. Seterusnya, buat topik contoh.

# Kafka-Topics.SH --Create-Zookeeper Localhost: 2181-Factor-Factor 1-Partisi 1-Tecmint Tekuk 

9. Senaraikan topik yang dibuat.

# Kafka-Topics.sh -zookeeper localhost: 2181 -list 

Kesimpulan

Dalam artikel ini, kita telah melihat cara memasang kluster node tunggal di Centos 7. Kami akan melihat cara memasang kluster kafka multinode dalam artikel seterusnya.