Memulai dengan Apache Kafka
Sebelum menginstal Apache Kafka, Anda harus menginstal Java dan akun pengguna dengan hak sudo. Selain itu, disarankan untuk memiliki RAM 2GB ke atas untuk menjalankan Kafka dengan benar.
Langkah-langkah berikut akan memandu Anda tentang cara menginstal Apache Kafka.
Menginstal Java
Java diperlukan untuk menginstal Kafka. Periksa apakah Ubuntu Anda memiliki Java yang diinstal dengan memeriksa versi menggunakan perintah berikut:
$ Jawa --Versi: kapan
Jika Java tidak diinstal, gunakan perintah berikut untuk menginstal Java OpenJDK.
$ sudo tepat Install default-jdk
Membuat Akun Pengguna
Dengan Java sudah terinstal, buat akun pengguna non-root. Kita juga perlu memberikannya beberapa hak istimewa sudo dengan menambahkan pengguna ke grup sudo menggunakan perintah berikut:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Masuk ke akun pengguna yang baru dibuat.
Menginstal Kafka
Anda perlu mengunduh Apache Kafka terbaru dari halaman unduhan resmi. Unduh file binernya menggunakan wget perintah seperti pada gambar berikut:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Setelah file biner diunduh, ekstrak menggunakan mengambil perintah dan pindahkan direktori yang diekstraksi ke /opt/kafka.
Selanjutnya, buat skrip systemd Untuk Penjaga kebun binatang dan Kafka layanan yang membantu dalam memulai dan menghentikan layanan.
Gunakan editor pilihan untuk membuat skrip systemd dan tempel konten berikut. Mulailah dengan Penjaga Kebun Binatang:
$ sudo nano / dll. / sistemd / sistem / penjaga kebun binatang.serviceTempelkan yang berikut ini:
[ Satuan ]Keterangan =Server Apache Zookeeper
Dokumentasi =http: // zookeeper.apache.org
Memerlukan =network.target remote-fs.target
Setelah =network.target remote-fs.target
[ Melayani ]
Jenis = sederhana
ExecStart = / memilih / kafka / tempat sampah / zookeeper-server-start.sh / memilih / kafka / konfigurasi / zookeeper.properties
ExecStop = / memilih / kafka / tempat sampah / zookeeper-server-stop.sh
Mengulang kembali = tidak normal
[ Install ]
Dicarioleh =multi-pengguna.target
Simpan file. Buat file systemd untuk Kafka dan rekatkan konten berikut:
Saat menempel, pastikan Anda mengatur jalur yang benar untuk Java yang Anda instal di sistem Anda.
[ Satuan ]Keterangan =Server Apache Kafka
Dokumentasi =http: // kafka.apache.org / dokumentasi.html
Memerlukan = penjaga kebun binatang.service
[ Melayani ]
Jenis = sederhana
Lingkungan = 'JAVA_HOME=/usr/lib/jvm/Java-11-openjdk-amd64'
ExecStart = / memilih / kafka / tempat sampah / kafka-server-start.sh / memilih / kafka / konfigurasi / server.properties
ExecStop = / memilih / kafka / tempat sampah / kafka-server-stop.sh
Mengulang kembali = tidak normal
[ Install ]
Dicarioleh =multi-pengguna.target
Setelah selesai, terapkan perubahan dengan memuat ulang daemon systemd:
Selanjutnya, aktifkan layanan Zookeeper dan mulai menggunakan perintah berikut:
$ sudo systemctl mulai zookeepe < kuat > r kuat >
Anda juga perlu melakukan hal yang sama untuk Kafka:
$ sudo systemctl mulai kafka
Setelah Anda memulai layanan, Anda dapat memverifikasi statusnya sebelum kami membuat topik di Kafka.
Hal yang baik dengan Kafka adalah ada banyak skrip yang dapat Anda gunakan.
Mari kita buat topik baru bernama linuxhint1 menggunakan kafka-topics.sh script dengan satu partisi dan replikasi. Gunakan perintah berikut:
$ sudo -di linuxhint / memilih / kafka / tempat sampah / kafka-topics.sh --membuat --bootstrap-server localhost: 9092 --replikasi-faktor 1 --partisi 1 --tema linuxhint1 
Perhatikan bahwa topik kita dibuat. Kita dapat melihat pesan sebelumnya untuk memverifikasinya.
Atau, Anda dapat membuat daftar topik yang tersedia menggunakan -daftar pilihan pada perintah berikut. Seharusnya mengembalikan topik yang kita buat:S
$ sudo -di linuxhint / memilih / kafka / tempat sampah / kafka-topics.sh --daftar --bootstrap-server localhost: 9092 
Dengan topik Kafka yang sedang dibuat, Anda dapat mulai menulis data aliran di Kafka-konsol-produser.sh dan periksa apakah itu tercermin di Anda konsumen.sh.
Buka shell Anda dan akses topik yang kami buat menggunakan producer.sh seperti yang ditunjukkan berikut ini:
$ sudo -di linuxhint / memilih / kafka / tempat sampah / kafka-console-producer.sh --broker-list localhost: 9092 --tema linuxhint1 
Selanjutnya, buka shell lain dan akses topik Kafka menggunakan consumer.sh.
Dengan dua cangkang terbuka, Anda dapat mengirim pesan di konsol produser. Apa pun yang Anda ketik tercermin di konsol konsumen yang mengonfirmasi bahwa Apache Kafka kami aktif dan berjalan.
Kesimpulan
Dengan panduan ini, Anda sekarang memiliki semua langkah yang dapat Anda ikuti untuk menginstal Apache Kafka di Ubuntu 22.04 Anda. Mudah-mudahan, Anda berhasil mengikuti setiap langkah dan menginstal Apache Kafka Anda dan membuat topik untuk menjalankan produksi konsumen dan produsen yang sederhana. Anda dapat menerapkan hal yang sama dalam produksi besar.