proto.lib

Transactional Producer - Ghi Atomic Nhiều Partition

Producer transactional gói nhiều lần ghi vào nhiều partition/topic thành một transaction atomic: hoặc tất cả commit, hoặc tất cả abort.

MessagingNâng cao2026-07-08
Transactional Producer - Ghi Atomic Nhiều Partition

Tags

#kafka#transaction#atomic-write#exactly-once#transaction-coordinator

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingNâng cao

Sink stream (Kafka) xuống Lakehouse: file cột + commit metadata

Sink connector đọc liên tục từ Kafka, gom bản ghi theo cửa sổ thời gian thành file cột (Parquet), rồi commit một snapshot metadata mới cho bảng lakehouse; exactly-once đạt được bằng cách gắn việc commit offset Kafka với chính việc commit snapshot đó, không tách rời.

#kafka#sink-connector#lakehouse#table-format
MessagingTrung bình

Idempotent Producer - Sequence Numbers

Producer idempotent gắn producer ID và sequence number cho mỗi message để broker phát hiện và loại bỏ bản ghi trùng do retry.

#kafka#idempotency#producer#sequence-number
MessagingNâng cao

Kafka Exactly-Once Semantics

Producer idempotent với PID+sequence, transaction dùng transactional.id, consumer đọc read-committed để đảm bảo exactly-once.

#kafka#exactly-once#idempotent-producer#transactions