KafkaConsumer group và rebalance trong Kafka với Spring Boot
Hiểu cách Kafka chia partition cho consumer group, khi nào rebalance xảy ra và cách giảm ảnh hưởng của rebalance trong ứng dụng Spring Boot.
Change Data Capture với Debezium và Kafka
Dùng Debezium đọc WAL của PostgreSQL, đẩy mọi thay đổi dữ liệu vào Kafka và tiêu thụ chúng bằng Spring Boot, không cần sửa code ghi dữ liệu.
Event sourcing với Kafka: lưu sự kiện thay vì trạng thái
Dùng Kafka làm event log cho Order: ghi sự kiện bất biến, dựng lại trạng thái bằng replay, tạo read model bằng projection. Kèm các giới hạn cần biết trước khi áp dụng.
Giám sát Kafka: consumer lag và các chỉ số cần theo dõi
Consumer lag là gì, cách đo bằng CLI, AdminClient và Micrometer, các chỉ số broker/producer/consumer nên theo dõi và cách đặt cảnh báo hợp lý.
Kafka producer: acks, idempotence và batching
Cấu hình acks, enable.idempotence, batch.size và linger.ms cho Kafka producer để không mất message, không trùng lặp mà vẫn đạt throughput cao.
Outbox pattern với Kafka: không mất sự kiện khi ghi database
Ghi database và gửi Kafka cùng lúc rất dễ mất sự kiện. Bài này hướng dẫn cài Outbox pattern với Spring Boot 3 và Kafka để hai bên luôn nhất quán.
Saga pattern với Kafka cho giao dịch phân tán: ví dụ đặt tour du lịch
Cài đặt Saga pattern kiểu orchestration với Spring Boot và Kafka. Đặt vé máy bay, khách sạn, thanh toán, và tự động bù trừ khi một bước thất bại.
Schema Registry và Avro/Protobuf trong Kafka với Spring Boot
Dùng Confluent Schema Registry với Avro và Protobuf trong Spring Boot 3 để kiểm soát định dạng message Kafka và tiến hóa schema an toàn.
Consumer group và rebalance trong Kafka: vì sao consumer bị dừng
Rebalance hoạt động ra sao, vì sao nó làm consumer ngừng xử lý message, và cách giảm thiểu bằng cấu hình poll, cooperative rebalancing, static membership.
Kafka retry và dead letter topic với Spring Kafka
Cấu hình retry blocking và non-blocking cho Kafka consumer trong Spring Boot 3, đẩy message lỗi sang dead letter topic và viết test kiểm chứng.
Thiết kế partition key trong Kafka: thứ tự message và phân tải
Cách Kafka chọn partition từ key, cách chọn key để giữ đúng thứ tự message mà không tạo hot partition, và những lỗi hay gặp với Spring Boot.
Producer Kafka: acks, retry và idempotence đúng cách
Tìm hiểu cách acks, retries và idempotence phối hợp để đảm bảo message không mất, không trùng khi producer gửi dữ liệu lên Kafka.
Kafka cơ bản: Topic, Partition và Offset
Giải thích ba khái niệm nền tảng của Kafka — topic, partition, offset — kèm ví dụ producer/consumer bằng Spring Boot.