Cara Menginstal Apache Kafka di Debian 9

Dalam tutorial ini, kami akan menunjukkan cara menginstal Apache Kafka di Debian 9. Bagi Anda yang belum tahu, Apache Kafka adalah agen pesan terdistribusi yang dirancang untuk menangani volume besar informasi real-time secara efektif Tidak seperti agen tradisional seperti ActiveMQ dan RabbitMQ, Kafka berfungsi sebagai sekelompok satu atau lebih server membuatnya sangat skalabel dan karena sifat terdistribusi, itu built-in toleransi kesalahan sementara memberikan throughput yang lebih besar bila dibandingkan dengan rekan-rekannya .

Artikel ini mengasumsikan Anda memiliki setidaknya pengetahuan dasar tentang Linux, mengetahui cara menggunakan shell, dan yang terpenting, Anda menghosting situs Anda di VPS Anda sendiri. Pemasangannya cukup sederhana dan mengasumsikan Anda sedang berjalan di akun root, jika tidak, Anda mungkin perlu menambahkan 'sudo ' ke perintah untuk mendapatkan hak akses root. Saya akan menunjukkan kepada Anda langkah demi langkah instalasi Apache Kafka di server Debian 9 (Stretch).

Prasyarat

• Server yang menjalankan salah satu sistem operasi berikut:Debian 9 (Stretch).
• Sebaiknya Anda menggunakan penginstalan OS baru untuk mencegah potensi masalah.
• Akses SSH ke server (atau cukup buka Terminal jika Anda menggunakan desktop).
• Seorang non-root sudo user atau akses ke root user . Kami merekomendasikan untuk bertindak sebagai non-root sudo user , namun, karena Anda dapat membahayakan sistem jika tidak berhati-hati saat bertindak sebagai root.

Instal Apache Kafka di Debian 9 Stretch

Langkah 1. Sebelum menginstal perangkat lunak apa pun, penting untuk memastikan sistem Anda mutakhir dengan menjalankan apt-get berikut perintah di terminal:

apt-get update
apt-get upgrade

Langkah 2. Menginstal Java.

Kafka ditulis dalam Java, Anda perlu menginstal Java di sistem Anda:

apt-get install default-jdk

Langkah 4. Menginstal Server Kafka.

Pertama, unduh dan ekstrak Kafka dari situs web Apache. Anda dapat menggunakan wget untuk mengunduh Kafka:

wget http://www-us.apache.org/dist/kafka/1.0.1/kafka_2.12-1.0.1.tgz

Ekstrak arsip yang diunduh menggunakan tar perintah di /opt/Kafka:

tar xzf kafka_2.12-1.0.1.tgz
mv kafka_2.12-1.0.1 /usr/local/kafka

Kafka menggunakan ZooKeeper, jadi pertama-tama, mulai server ZooKeeper di sistem Anda:

cd /usr/local/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

Mari kita buat topik bernama “NewTopic” dengan satu partisi dan hanya satu replika:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic NewTopic
Created topic "NewTopic".

Sekarang Anda dapat melihat topik yang dibuat di Kafka dengan menjalankan perintah daftar topik:

bin/kafka-topics.sh --list --zookeeper localhost:2181

NewTopic

Kafka juga memiliki konsumen baris perintah untuk membaca data dari klaster Kafka dan menampilkan pesan ke output standar:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning

Welcome to kafka
This is my New topic

Selamat! Anda telah berhasil menginstal Apache Kafka. Terima kasih telah menggunakan tutorial ini untuk menginstal Instal Kompilator Kotlin pada sistem Debian 9 Stretch. Untuk bantuan tambahan atau informasi berguna, kami sarankan Anda memeriksa Apache Kafkaweb resmi situs.