Konsumen Kafka

Pengantar Apache Kafka

Mike Metzger

Data Engineering Consultant

Apa itu konsumen?

  • Membaca pesan dari topik Kafka
    • Kadang disebut subscriber
  • Kafka menyajikan pesan dalam topik kepada konsumen
  • Dapat memiliki banyak konsumen
  • Konsumen dapat membaca dari satu atau beberapa topik
Pengantar Apache Kafka

Jenis konsumen

  • Banyak jenis konsumen
    • Command-line
      • kafka-console-consumer.sh
    • Python
    • Java
    • Banyak bahasa lain
    • Kafka Connect
Pengantar Apache Kafka

kafka-console-consumer.sh

  • Ada di folder bin/, bersama alat Kafka lain
    • bin/kafka-console-consumer.sh
  • Beberapa opsi, sebagian wajib
  • Opsi wajib sama dengan kafka-console-producer:
    • --topic
    • --bootstrap-server
  • Default: membuka koneksi, menampilkan pesan real-time, dan menjaga posisi.
  • Gunakan Ctrl-C untuk keluar
Pengantar Apache Kafka

Argumen opsional

  • --from-beginning
    • Meminta Kafka mengirim semua pesan di topik, termasuk yang sudah dibaca.
  • --max-messages <number>
    • Membaca hingga jumlah pesan maksimum lalu keluar
Pengantar Apache Kafka

Contoh interaktif

  • Contoh interaktif
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
    --topic testing --from-beginning

Ini pesan pertama
Ini pesan kedua
Ini pesan ketiga
<ctrl+c untuk keluar>
Pengantar Apache Kafka

Contoh non-interaktif

  • Non-interaktif
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 /
  --topic testing --from-beginning --max-messages 2

Ini pesan pertama
Ini pesan kedua
<keluar otomatis>
Pengantar Apache Kafka

Ayo berlatih!

Pengantar Apache Kafka

Preparing Video For Download...