Spring Cloud Stream cung cấp cho chúng ta dependency spring-cloud-stream-test-binder, giúp chúng ta có thể dễ dàng viết unit test cho các ứng dụng có sử dụng Spring Cloud Stream mà không cần phải gọi tới các message broker thật. Các bạn có thể khai… Read More
Từ v4 trở đi, Apache Kafka sẽ sử dụng KRaft cho phần cluster management thay vì Apache ZooKeeper. Do đó, các bạn không cần up và running container cho Apache ZooKeeper như trong hướng dẫn của bài viết này nữa. Trong bài viết này, mình… Read More
Partitioning trong message queue là cơ chế chia nhỏ các topic hoặc queue thành nhiều partition khác nhau. Mỗi partition sẽ lưu trữ một phần của dữ liệu và các dữ liệu này sẽ được xử lý song song. Nhờ đó mà quá trình nhận… Read More
Spring Cloud Stream hỗ trợ chức năng consumer routing, cho phép chúng ta quyết định consumer nào sẽ consume message do một producer nhất định gửi tới. Chúng ta có thể route message sử dụng message header, payload content hay header content với expression. Cụ… Read More