Kafka konzumenti

Introduction to Apache Kafka

Mike Metzger

Data Engineering Consultant

Co je konzument?

  • Čte zprávy z Kafka témat
    • Někdy nazýváni odběratelé
  • Kafka doručuje zprávy z témat konzumentům
  • Může existovat mnoho konzumentů
  • Konzumenti mohou číst z jednoho nebo více témat
Introduction to Apache Kafka

Typy konzumentů

  • Mnoho různých typů konzumentů
    • Příkazová řádka
      • kafka-console-consumer.sh
    • Python
    • Java
    • Mnohé další jazyky
    • Kafka Connect
Introduction to Apache Kafka

kafka-console-consumer.sh

  • Nachází se ve složce bin/ spolu s dalšími nástroji Kafka
    • bin/kafka-console-consumer.sh
  • Několik přepínačů, některé povinné
  • Povinné přepínače jsou stejné jako u kafka-console-producer:
    • --topic
    • --bootstrap-server
  • Ve výchozím nastavení otevře připojení, kde se zprávy zobrazují v reálném čase, a udržuje pozici.
  • Pro ukončení použijte Ctrl-C
Introduction to Apache Kafka

Volitelné argumenty

  • --from-beginning
    • Systému Kafka sdělí, aby odeslal všechny zprávy v tématu, včetně již přečtených.
  • --max-messages <number>
    • Slouží ke čtení maximálního počtu zpráv před ukončením
Introduction to Apache Kafka

Interaktivní příklad

  • Interaktivní příklad
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>
Introduction to Apache Kafka

Neinteraktivní příklad

  • Neinteraktivní
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>
Introduction to Apache Kafka

Pojďme si procvičit!

Introduction to Apache Kafka

Preparing Video For Download...