Producenci Kafka

Wprowadzenie do Apache Kafka

Mike Metzger

Data Engineering Consultant

Czym jest producent?

  • Zapisuje wiadomości do tematów Kafka
    • Czasami nazywany wydawcą
  • Wiadomości są przechowywane w Kafka do późniejszego użycia
  • Może istnieć wielu producentów
  • Producent może zapisywać do jednego lub wielu tematów
Wprowadzenie do Apache Kafka

Typy producentów

  • Wiele rodzajów producentów
    • Wiersz poleceń
      • kafka-console-producer.sh
    • Python
    • Java
    • Inne języki
    • Kafka Connect
Wprowadzenie do Apache Kafka

kafka-console-producer.sh

  • Znajduje się w folderze bin/, wraz z innymi narzędziami Kafka
    • bin/kafka-console-producer.sh
  • Kilka opcji wiersza poleceń – niektóre wymagane, inne nie
  • Wymagane opcje:
    • --bootstrap-server – Określa serwer do użycia
      • --bootstrap-server localhost:9092
    • --topic
      • --topic phishing-sites
  • Domyślnie otwiera połączenie, w którym można wpisywać wiadomości
    • Wyjście: Ctrl-C
  • Można też użyć symbolu | do przesyłania wiadomości
Wprowadzenie do Apache Kafka

Przykład

  • Tryb interaktywny
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testing

>This is the first message
>This is the second message
>This is the third message
<ctrl+c to exit>
  • Tryb nieinteraktywny
echo "This is the first message" |
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testing
Wprowadzenie do Apache Kafka

Czas na ćwiczenia!

Wprowadzenie do Apache Kafka

Preparing Video For Download...