Welcome to MikeDaDev's Blog – notes on Java, backend & system design.

Explore
MikeDaDev's Blog

#kafka

Things I've written about #kafka
  • transactional outbox & idempotent consumer

    Xử lý bài toán Dual-Write cho đúng: Transactional Outbox với Debezium SMT, kỹ thuật SELECT FOR UPDATE SKIP LOCKED, vì sao Kafka transaction không cứu được bạn ở đây, và cách làm Idempotent Consumer chạy được trên production với RDBMS (kèm Redis làm lớp lọc nhanh).

  • CDC với Debezium & cache invalidation

    Change Data Capture (CDC) với Debezium nhìn từ bên trong: PostgreSQL logical decoding (pgoutput) chạy ra sao, vì sao dual-write dính partial failure và race condition, cách dùng Outbox Event Router (SMT), chống cache stampede và canh replication slot trên production.

  • in java / kafka

    kafka advance

    Phần hai của loạt Kafka: những thứ bạn sẽ cần khi hệ thống lớn dần, từ Kafka Connect, Schema Registry, bảo mật, exactly-once, testing, chạy Kafka trên K8s cho tới playbook xử lý sự cố.

  • in java / kafka

    kafka basic

    kafka là gì, sao lại chọn kafka mà không phải rabbitmq? bài này đi qua kiến trúc kafka, cách dùng với spring boot, mấy pattern hay gặp ngoài đời và checklist trước khi lên production.