Kafka tüketicileri

Apache Kafka'ya Giriş

Mike Metzger

Data Engineering Consultant

Tüketici nedir?

  • Kafka konularından mesaj okur
    • Bazen aboneler de denir
  • Kafka, konularda saklanan mesajları tüketicilere sağlar
  • Birçok tüketici olabilir
  • Tüketiciler bir veya birden çok konudan okuyabilir
Apache Kafka'ya Giriş

Tüketici türleri

  • Birçok farklı türde tüketici
    • Komut satırı
      • kafka-console-consumer.sh
    • Python
    • Java
    • Daha birçok dil
    • Kafka Connect
Apache Kafka'ya Giriş

kafka-console-consumer.sh

  • Diğer Kafka araçlarıyla bin/ klasöründe bulunur
    • bin/kafka-console-consumer.sh
  • Birkaç seçenek vardır, bazıları zorunlu
  • Zorunlu seçenekler kafka-console-producer ile aynıdır:
    • --topic
    • --bootstrap-server
  • Varsayılan olarak, mesajların anlık göründüğü ve konumu koruyan bir bağlantı açar.
  • Çıkmak için Ctrl-C kullan
Apache Kafka'ya Giriş

İsteğe bağlı argümanlar

  • --from-beginning
    • Kafka'ya, daha önce okunmuş olsa bile konudaki tüm mesajları göndermesini söyler.
  • --max-messages <number>
    • Çıkmadan önce en fazla şu kadar mesaj okumak için kullanılır
Apache Kafka'ya Giriş

Etkileşimli örnek

  • Etkileşimli örnek
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
    --topic testing --from-beginning

This is the first message
This is the second message
This is the third message
<ctrl+c to exit>
Apache Kafka'ya Giriş

Etkileşimli olmayan örnek

  • Etkileşimli değil
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 /
  --topic testing --from-beginning --max-messages 2

This is the first message
This is the second message
<automatically exits>
Apache Kafka'ya Giriş

Hadi pratik yapalım!

Apache Kafka'ya Giriş

Preparing Video For Download...