Nhà sản xuất Kafka

Giới thiệu về Apache Kafka

Mike Metzger

Data Engineering Consultant

Producer là gì?

  • Ghi thông điệp vào chủ đề (topic) Kafka
    • Còn gọi là publisher
  • Thông điệp gửi qua producer được lưu trên Kafka để dùng sau
  • Có thể có nhiều producer
  • Producer có thể ghi vào một hoặc nhiều topic
Giới thiệu về Apache Kafka

Các loại producer

  • Có nhiều loại producer
    • Dòng lệnh
      • kafka-console-producer.sh
    • Python
    • Java
    • Nhiều ngôn ngữ khác
    • Kafka Connect
Giới thiệu về Apache Kafka

kafka-console-producer.sh

  • Nằm trong thư mục bin/, cùng các công cụ Kafka khác
    • bin/kafka-console-producer.sh
  • Có nhiều tùy chọn dòng lệnh, một số bắt buộc, số khác không
  • Tùy chọn bắt buộc:
    • --bootstrap-server - Chỉ định máy chủ sử dụng
      • --bootstrap-server localhost:9092
    • --topic
      • --topic phishing-sites
  • Mặc định mở kết nối để gõ thông điệp
    • Dùng Ctrl-C để thoát
  • Cũng có thể dùng ký hiệu | để truyền thông điệp
Giới thiệu về Apache Kafka

Ví dụ

  • Ví dụ tương tác
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>
  • Không tương tác
echo "This is the first message" |
bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic testing
Giới thiệu về Apache Kafka

Hãy luyện tập!

Giới thiệu về Apache Kafka

Preparing Video For Download...