Trong bài viết trước, chúng ta đã tìm hiểu chi tiết 2 loại exception handlers trong Spring for Apache Kafka Streams là DeserializationExceptionHandler và ProcessingExceptionHandler. Trong bài viết này, chúng ta hãy cùng nhau tìm hiểu exception handler còn lại là ProductionExceptionHandler, các bạn nhé!… Read More

Để handle các exception có thể xảy ra trong các ứng dụng có sử dụng Spring for Apache Kafka Streams, các bạn có thể khai báo các cấu hình như sau: Configuration Handles Ví dụ DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG Handle các exception liên quan đến việc deserialization các… Read More

Các phương thức join() trong Spring for Apache Kafka Streams là các inner join, dùng để join các message có cùng key được publish vào 2 Apache Kafka topics. Ví dụ như mình có 2 topic là customers và orders. Để có thể join các… Read More

Trong bài viết trước, mình đã giới thiệu với các bạn về Spring for Apache Kafka cùng với Apache Kafka Streams. Mình cũng đã hướng dẫn cho các bạn cách sử dụng class KStream để consume và áp dụng một số operation với các stream… Read More