Consumatori Kafka

Introducere în Apache Kafka

Mike Metzger

Data Engineering Consultant

Ce este un consumator?

  • Citește mesaje din topicuri Kafka
    • Numiți uneori abonați
  • Kafka furnizează mesajele stocate în topicuri consumatorilor
  • Pot exista mai mulți consumatori
  • Consumatorii pot citi din unul sau mai multe topicuri
Introducere în Apache Kafka

Tipuri de consumatori

  • Tipuri diverse de consumatori
    • Linie de comandă
      • kafka-console-consumer.sh
    • Python
    • Java
    • Alte limbaje
    • Kafka Connect
Introducere în Apache Kafka

kafka-console-consumer.sh

  • Se găsește în folderul bin/, alături de alte instrumente Kafka
    • bin/kafka-console-consumer.sh
  • Mai multe opțiuni, unele obligatorii
  • Opțiunile obligatorii sunt aceleași ca la kafka-console-producer:
    • --topic
    • --bootstrap-server
  • Implicit, deschide o conexiune unde mesajele apar în timp real și poziția este menținută.
  • Folosiți Ctrl-C pentru a ieși
Introducere în Apache Kafka

Argumente opționale

  • --from-beginning
    • Indică sistemului Kafka să trimită toate mesajele din topic, inclusiv cele deja citite.
  • --max-messages <number>
    • Citește cel mult un număr specificat de mesaje, apoi iese
Introducere în Apache Kafka

Exemplu interactiv

  • Exemplu interactiv
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>
Introducere în Apache Kafka

Exemplu non-interactiv

  • Non-interactiv
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>
Introducere în Apache Kafka

Să exersăm!

Introducere în Apache Kafka

Preparing Video For Download...