Bermula dengan Apache Kafka
Sebelum memasang Apache Kafka, anda mesti memasang Java dan akaun pengguna dengan keistimewaan sudo. Selain itu, adalah disyorkan untuk mempunyai RAM 2GB dan ke atas untuk menjalankan Kafka dengan betul.
Langkah-langkah berikut akan membimbing anda tentang cara memasang Apache Kafka.
Memasang Java
Java diperlukan untuk memasang Kafka. Semak sama ada Ubuntu anda mempunyai Java yang dipasang dengan menyemak versi menggunakan arahan berikut:
$ java --versi
Jika Java tidak dipasang, gunakan arahan berikut untuk memasang Java OpenJDK.
$ sudo apt pasang default-jdk
Mencipta Akaun Pengguna
Dengan Java sudah dipasang, buat akaun pengguna bukan root. Kami juga perlu memberikan beberapa keistimewaan sudo dengan menambahkan pengguna ke kumpulan sudo menggunakan arahan berikut:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Log masuk ke akaun pengguna yang baru dibuat.
Memasang Kafka
Anda perlu memuat turun Apache Kafka terkini dari halaman muat turun rasmi. Muat turun fail binarinya menggunakan wget perintah seperti yang ditunjukkan dalam berikut:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Setelah fail binari dimuat turun, ekstraknya menggunakan fail mengambil arahan dan alihkan direktori yang diekstrak ke /opt/kafka.
Seterusnya, buat skrip systemd untuk Penjaga zoo dan juga Kafka perkhidmatan yang membantu dalam memulakan dan menghentikan perkhidmatan.
Gunakan editor pilihan untuk mencipta skrip systemd dan tampal kandungan berikut. Mulakan dengan Penjaga Zoo:
$ sudo nano / dan lain-lain / sistemd / sistem / zookeeper.serviceTampal yang berikut:
[ Unit ]Penerangan =Pelayan Apache Zookeeper
Dokumentasi =http: // zookeeper.apache.org
Memerlukan =network.target remote-fs.target
Selepas =network.target remote-fs.target
[ Perkhidmatan ]
taip =mudah
ExecStart = / memilih / kafka / tong sampah / zookeeper-server-start.sh / memilih / kafka / konfigurasi / zookeeper.properties
ExecStop = / memilih / kafka / tong sampah / zookeeper-server-stop.sh
Mula semula =on-abnormal
[ Pasang ]
WantedBy =berbilang pengguna.sasaran
Simpan fail. Buat fail systemd untuk Kafka dan tampal kandungan berikut:
Apabila menampal, pastikan anda menetapkan laluan yang betul untuk Java yang anda pasang dalam sistem anda.
[ Unit ]Penerangan =Pelayan Apache Kafka
Dokumentasi =http: // kafka.apache.org / dokumentasi.html
Memerlukan =zookeeper.service
[ Perkhidmatan ]
taip =mudah
Persekitaran = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / memilih / kafka / tong sampah / kafka-server-start.sh / memilih / kafka / konfigurasi / pelayan.sifat
ExecStop = / memilih / kafka / tong sampah / kafka-server-stop.sh
Mula semula =on-abnormal
[ Pasang ]
WantedBy =berbilang pengguna.sasaran
Setelah selesai, gunakan perubahan dengan memuat semula daemon systemd:
Seterusnya, dayakan perkhidmatan Zookeeper dan mulakannya menggunakan arahan berikut:
$ sudo systemctl mulakan zookeepe < kuat > r kuat >
Anda juga perlu melakukan perkara yang sama untuk Kafka:
$ sudo systemctl mulakan kafka
Sebaik sahaja anda memulakan perkhidmatan, anda boleh mengesahkan status mereka sebelum kami membuat topik dalam Kafka.
Perkara yang baik dengan Kafka ialah terdapat banyak skrip yang boleh anda gunakan.
Mari buat topik baharu bernama linuxhint1 menggunakan kafka-topics.sh skrip dengan satu partition dan replikasi. Gunakan arahan berikut:
$ sudo -dalam linuxhint / memilih / kafka / tong sampah / kafka-topics.sh --buat --bootstrap-server localhost: 9092 --faktor replikasi 1 --sekatan 1 --topik linuxhint1 
Ambil perhatian bahawa topik kami telah dibuat. Kita boleh melihat mesej sebelumnya untuk mengesahkannya.
Sebagai alternatif, anda boleh menyenaraikan topik yang tersedia menggunakan –senarai pilihan dalam arahan berikut. Ia sepatutnya mengembalikan topik yang kami buat:S
$ sudo -dalam linuxhint / memilih / kafka / tong sampah / kafka-topics.sh --senarai --bootstrap-server localhost: 9092 
Dengan topik Kafka dibuat, anda boleh mula menulis data aliran pada Kafka-console-producer.sh dan semak sama ada ia mencerminkan dalam anda pengguna.sh.
Buka shell anda dan akses topik yang kami buat menggunakan producer.sh seperti yang ditunjukkan dalam yang berikut:
$ sudo -dalam linuxhint / memilih / kafka / tong sampah / kafka-console-producer.sh --senarai broker localhost: 9092 --topik linuxhint1 
Seterusnya, buka cangkerang lain dan akses topik Kafka menggunakan consumer.sh.
Dengan dua cengkerang dibuka, anda boleh menghantar mesej pada konsol pengeluar. Apa sahaja yang anda taip ditunjukkan dalam konsol pengguna yang mengesahkan bahawa Apache Kafka kami telah berfungsi dan berjalan.
Kesimpulan
Dengan panduan ini, anda kini mempunyai semua langkah yang boleh anda ikuti untuk memasang Apache Kafka dalam Ubuntu 22.04 anda. Mudah-mudahan, anda berjaya mengikuti setiap langkah dan memasang Apache Kafka anda dan mencipta topik untuk menjalankan pengeluaran pengguna dan pengeluar yang mudah. Anda boleh melaksanakan perkara yang sama dalam pengeluaran besar.