Apache Kafka

Berkas dan Direktori Penting

• Direktori instalasi utama Kafka: /opt/kafka
• Berkas konfigurasi broker Kafka: /opt/kafka/config/server.properties
• Direktori log Kafka (log broker, peristiwa yang disimpan): /opt/kafka/logs
• Biner Kafka dan alat baris perintah (CLI) (kafka-topics.sh, kafka-console-producer.sh, dsb.): /opt/kafka/bin
• Unit layanan Systemd untuk mengelola Kafka: /etc/systemd/system/kafka.service

Layanan Kafka

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Buat Topik

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Periksa detail topik:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Membuat Acara (Pesan)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Tuliskan satu acara per baris.

Tekan Ctrl+C untuk keluar.

Mengonsumsi Acara

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

Tekan Ctrl+C untuk berhenti membaca.

Acara dapat diakses oleh beberapa klien secara berulang-ulang.

Catatan & Pemecahan Masalah

• Catatan Kafka: /opt/kafka/logs
• Jurnal Systemd: sudo journalctl -u kafka -f
• Pastikan port-port 9092 (broker) dan 9093 (pengendali) terbuka.