How to install Apache Kafka on Ubuntu/Debian

Apache Kafka adalah platform streaming terdistribusi. Ini dapat digunakan untuk apa saja mulai dari broker pesan terdistribusi hingga platform untuk memproses aliran data.

Nah untuk menjalankan kafka terlebih dahulu teman-teman menginstall Java 8

bisa dengan perintah berikut:

#apt-get install openjdk-8-jdk

kemudian download kafka versi 2.11 dengan perintah

#wget https://archive.apache.org/dist/kafka/1.0.0/kafka_2.11-1.0.0.tgz

Setelah di download pastikan java path pada /root/.bashrc atau /etc/profile sudah ada, jika belum lakukan perintah

#nano /root/.bashrc

lalu tambahkan konfigurasi

export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64/jre/

setelah itu aktifkan bashrc atau profile dengan perintah

#source /root/.bashrc

#source  /etc/profile

kemudian extract terlebih dahulu kafka yang telah didownload

#tar xvzf kafka_2.11-1.0.0.tgz

lalu pindahkan ke direktori /opt

#mv kafka_2.11-1.0.0 /opt/

kemudian masuk ke direktori kafka yang telah dipindahkan

#cd /opt/kafka_2.11-1.0.0

kemudian Jalankan Zookeper dan akan listenin pada port 2181

#bin/zookeeper-server-start.sh config/zookeeper.properties

Lalu konfigurasi pada /opt/kafka_2.11-1.0.0/config/server.properties

broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logs

Kemudian jalankan server.properties tadi

bin/kafka-server-start.sh config/server.properties

Lalu buat topic

bin/kafka-topics.sh --create --topic [TOPIC ANDA] --zookeeper localhost:2181 --partitions 1 --replication-factor 1

kemudian buat producers

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic [TOPIC ANDA]

Kemudian consumers

bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic [TOPIC ANDA] --from-beginning

lalu ketikka sesuatu pada producer dan lihat pada consumer maka akan seperti ini