proto.lib

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.

MessagingNâng cao2026-07-14
Kafka Streams - Interactive Queries

Tags

#kafka-streams#interactive-queries#state-store#local-query#rest-api

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

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.

#kafka-streams#ktable#state-store#changelog-topic
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
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