Kafka tüketicileri

Apache Kafka'ya Giriş

Mike Metzger

Data Engineering Consultant

Tüketici nedir?

  • Kafka konularından (topic) mesaj okur
    • Bazen abone (subscriber) denir
  • Kafka, konulardaki 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 türde tüketici vardır
    • Komut satırı
      • kafka-console-consumer.sh
    • Python
    • Java
    • Diğer 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
  • Bazı zorunlu olmak üzere çeşitli seçenekler vardır
  • Zorunlu seçenekler kafka-console-producer ile aynıdır:
    • --topic
    • --bootstrap-server
  • Varsayılan olarak, mesajların gerçek zamanlı göründüğü ve konumu koruyan bir bağlantı açar.
  • Çıkmak için Ctrl-C kullanın
Apache Kafka'ya Giriş

İsteğe bağlı argümanlar

  • --from-beginning
    • Kafka'ya, önceden okunmuş olsa bile, konudaki tüm mesajları göndermesini söyler.
  • --max-messages <number>
    • Çıkmadan önce en fazla belirtilen sayıda 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şimsiz örnek

  • Etkileşimsiz
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...