Cara menginstal apache kafka di centos/rhel 7

Apache Kafka adalah mesin pesan yang kuat, yang banyak digunakan Data besar proyek dan Analisis Data lingkaran kehidupan. Ini adalah platform open-source untuk membangun jaringan pipa streaming data waktu nyata. Ini adalah platform sub-subcribe yang didistribusikan dengan keandalan, skalabilitas, dan daya tahan.

Kita bisa memiliki Kafka sebagai mandiri atau sebagai cluster. Kafka menyimpan data streaming, dan dapat dikategorikan sebagai Topik. Itu Tema akan memiliki sejumlah partisi sehingga dapat menangani jumlah data yang sewenang -wenang. Juga, kita dapat memiliki beberapa replika untuk toleran terhadap kesalahan seperti yang kita miliki HDFS. Dalam kluster kafka, broker adalah komponen yang menyimpan data yang dipublikasikan.

Zookeeper adalah layanan wajib untuk menjalankan a Kafka cluster, seperti yang digunakan untuk mengelola koordinasi broker kafka. Zookeeper memainkan peran kunci antara produsen dan konsumen di mana ia bertanggung jawab untuk mempertahankan keadaan semua broker.

Di artikel ini, kami akan menjelaskan cara menginstal Apache Kafka Dalam satu simpul Centos 7 atau RHEL 7.

Menginstal Apache Kafka di Centos 7

1. Pertama, Anda perlu menginstal Jawa di sistem Anda untuk dijalankan Apache Kafka tanpa kesalahan. Jadi, instal versi default yang tersedia Jawa menggunakan perintah yum berikut dan verifikasi Jawa versi seperti yang ditunjukkan.

# yum -y menginstal java -1.8.0 -OPENJDK # JAVA -VERSION 

2. Selanjutnya, unduh versi stabil terbaru Apache Kafka dari situs web resmi atau gunakan perintah wget berikut untuk mengunduhnya secara langsung dan mengekstraknya.

# wget https: // mirrors.Estointernet.di/apache/kafka/2.7.0/kafka_2.13-2.7.0.TGZ # TAR -XZF KAFKA_2.13-2.7.0.tgz 

3. Buat tautan simbolis untuk kafka paket, lalu tambahkan jalur lingkungan kafka ke .Bash_profile file dan kemudian inisialisasi seperti yang ditunjukkan.

# ln -s kafka_2.13-2.7.0 kafka # echo "jalur ekspor = $ path:/root/kafka_2.13-2.7.0/bin ">> ~/.Bash_profile # Sumber ~/.Bash_profile 

4. Selanjutnya, mulailah Penjaga kebun binatang, yang datang bawaan dengan Kafka kemasan. Karena ini adalah kluster simpul tunggal, Anda dapat memulai zookeeper dengan properti default.

# zookeeper-server-start.sh -daemon/root/kafka/config/zookeeperer.properti 

5. Validasi apakah ZooKeeper dapat diakses atau tidak dengan sederhana telnet ke Penjaga kebun binatang pelabuhan 2181.

# telnet localhost 2181 

6. Memulai Kafka dengan properti defaultnya.

# kafka-server-start.sh -daemon/root/kafka/config/server.properti 

7. Validasi apakah Kafka dapat diakses atau tidak hanya dengan telnet ke port kafka 9092

# telnet localhost 9092 

8. Selanjutnya, buat topik sampel.

# Kafka-Topics.SH --Create --zookeeper Localhost: 2181--Replikasi-Faktor 1 --partisi 1-Tecmint Topik 

9. Daftar topik yang dibuat.

# Kafka-Topics.SH --zookeeper Localhost: 2181 -daftar 

Kesimpulan

Di artikel ini, kita telah melihat cara menginstal satu node kafka cluster di Centos 7. Kita akan melihat cara menginstal cluster kafka multinode di artikel berikutnya.