proto.lib

Kafka Streams - KTable, State Store và Changelog Topic

Kafka Streams biểu diễn trạng thái tổng hợp dưới dạng KTable, lưu trong local state store và sao lưu bền vững qua changelog topic.

MessagingNâng cao2026-07-14
Kafka Streams - KTable, State Store và Changelog Topic

Tags

#kafka-streams#ktable#state-store#changelog-topic#aggregation

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

State Store cục bộ (RocksDB) trong Stream Processing

Một stream processor có trạng thái (aggregate/join) lưu state ngay trên đĩa cục bộ bằng embedded key-value store (thường là RocksDB), và sao lưu mọi thay đổi vào một changelog topic để có thể rebuild lại khi instance chết; nhưng state phình vô hạn nếu không có TTL, còn restore sau rebalance có thể mất nhiều phút downtime.

#stream-processing#state-store#rocksdb#changelog-topic
MessagingNâng cao

Kafka Streams - Interactive Queries

Interactive Queries cho phép ứng dụng ngoài truy vấn trực tiếp state store cục bộ của Kafka Streams mà không cần hệ CSDL riêng.

#kafka-streams#interactive-queries#state-store#local-query
MessagingNâng cao

Tombstone và delete.retention.ms trong compacted topic

Trong compacted topic, một record có value null là tombstone đánh dấu xoá key; nó phải tồn tại đủ lâu (delete.retention.ms) để mọi consumer và mọi tiến trình rebuild state-store đọc được trước khi log compaction xoá hẳn nó, nếu không consumer offline lâu sẽ không bao giờ biết key đã bị xoá.

#kafka#compaction#tombstone#delete-retention