Chủ đề (topic) trong Kafka

Giới thiệu về Apache Kafka

Mike Metzger

Data Engineering Consultant

Topic là gì?

Topic là nhóm logic của sự kiện
- Tương tự một bảng trong cơ sở dữ liệu quan hệ
- Nhật ký sự kiện
- Thông điệp là bất biến
- Có thể đọc hoặc ghi thông điệp, nhưng không thể sửa
- Có thể xóa thông điệp theo tuổi thọ

Minh họa topic Kafka.png

Tạo topic

Có nhiều cách tạo topic

Ta sẽ dùng script bin/kafka-topics.sh

bin/kafka-topics.sh 
    --bootstrap-server <server> 
    --topic <topicname>
    --create

Ví dụ

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create

Created topic orders

Các biến thể khác

Tham số tùy chọn cho bin/kafka-topics.sh --create
- --replication-factor <x>
  - Đặt hệ số sao chép cho topic
- --partitions <x>
  - Chỉ định số phân vùng thủ công

Ví dụ

$ bin\kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create --replication-factor 3 \
--partitions 3

Created topic orders

--describe

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --describe
- Lấy chi tiết cấu hình của topic

Ví dụ

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
   --topic orders --describe

Topic: orders-new TopicId: <topicid> PartitionCount: 3 ReplicationFactor: 1    
  Configs:
    Topic: orders-new    Partition: 0    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 1    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 2    Leader: 0    Replicas: 0    Isr: 0

Xóa topic

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --delete
- Xóa một topic khỏi máy chủ Kafka
- Xóa topic sẽ xóa toàn bộ thông điệp trong topic

Ví dụ

$ bin/kafka-topics.sh --bootstrap-server localhost:9092
  --topic orders --delete

Ayo berlatih!

Giới thiệu về Apache Kafka