Em cũng mới áp dụng kafka. ServiceA gửi 1 event lên queue , nếu ServiceB đang lỗi thì khi connect lại nó nhận và xử lý các event chưa được xử lý lúc chết. E thấy đây là 1 tính năng hay , mong a sau này phân tích về nó rõ hơn ạ . E cảm ơn
hình như các queue service như RabbitMQ cũng có cơ chế như này ấy bạn. Theo mình biết ở bên RabbitMQ thì nó là cơ chế acknowledge message ấy: cho dù service nhận message nhưng ko acknowledge message thì message vẫn còn trong queue.
Dạ em chào anh, em đang làm một project có sử dụng kafka. Em có tham khảo thì thấy có thể sử dụng local dependencie cấu hình một kafka ở một service common để sử dụng chung có vấn đề gì không ạ.
em lại thắc mắc tý anh ạ, trong 1 topics có thể có nhiều message và trong message có các kiểu datatype khác nhau có thể là class User ,.... mà ko phải là class String nữa , vậy thì làm thế để phía consumer ở service khác nhận được 1 cái message đó ạ. Tại vì em thấy listener nhận được cần truyền message có datatype giống cái datatype mà producer gửi lên , nhưng mà phía consumer của sercice khác lại không có ạ datatype này ạ ..
@@DevteriaChannel dạ. v nếu ở phía producer của service A push 1 message là datatype chỉ có ở serviceA nhưng phía consumer của service B không có datatype như ở service A thì Listener ở service B sử lí như thế nào ạ ?
ko còn từ nào để diễn tả luôn, tuyệt vời quá a ơi, dân dev java như tụi em cảm ơn a nhiều lắm.
đây rồi, chủ đề e đang tìm kiếm, mong anh làm thêm nhiều case về kafka
1 tuần anh ra thêm 1 2 video được kh ạ, anh làm videos chủ đề hay mà ít video quá đợi anh hoài luôn
Mong a ra nhiều video hơn ạ🎉. Cảm ơn a nhiều
vừa nãy cmt :))) đã có video quá đẽ
a làm video về saga pattern được không ạ
Kafka vua của message broker :v
Này xài cho saga pattern thì quá đẹp anh nhỉ
anh có thể nói thêm về việc config partition, replicate , broker cluster nữa không ạ
Tuần ra 2 video của seri microservice đi anh😊😊
anh ra video hướng dẫn cách tạo sonarqube trên docker được không ạ
A ơi, a hướng dẫn deploy code lên server đi a
Em cũng mới áp dụng kafka. ServiceA gửi 1 event lên queue , nếu ServiceB đang lỗi thì khi connect lại nó nhận và xử lý các event chưa được xử lý lúc chết. E thấy đây là 1 tính năng hay , mong a sau này phân tích về nó rõ hơn ạ . E cảm ơn
hình như các queue service như RabbitMQ cũng có cơ chế như này ấy bạn. Theo mình biết ở bên RabbitMQ thì nó là cơ chế acknowledge message ấy: cho dù service nhận message nhưng ko acknowledge message thì message vẫn còn trong queue.
@@ngocquangnguyen3846 ok cảm ơn bạn nha
a cho e hỏi là: tại sao ko dùng @Async có sẵn trong spring boot mà lại dùng kafka ạ
Kafka để giải bài toán hoàn toàn khác nhé.
anh cho em hỏi tại sao ko pull kafka image về trực tiếp mà lại cần tạo thêm file docker-compose z anh
Vì có nhiều biến môi trường cần set nên anh đưa ra file Docker compose để dễ đọc hơn thôi
mình có làm thêm bài giảng ứng dụng redis vào 1 ví dự thực tế k ạ anh ?
Hiện tại thì anh chưa có plan cho Redis nha. Nhưng cũng có nhiều bạn hỏi nên anh sẽ cân nhắc một case cụ thể nào đó trong series Microservices
Dạ em chào anh, em đang làm một project có sử dụng kafka. Em có tham khảo thì thấy có thể sử dụng local dependencie cấu hình một kafka ở một service common để sử dụng chung có vấn đề gì không ạ.
Đó cũng là một cách. Cách này sẽ đòi hỏi một số kỹ thuật để đảm bảo hoạt động khi deploy ứng dụng.
@@DevteriaChannel Vậy phướng án nào là best pratice ạ
series này khoảng bao lâu là xong v anh
em lại thắc mắc tý anh ạ, trong 1 topics có thể có nhiều message và trong message có các kiểu datatype khác nhau có thể là class User ,.... mà ko phải là class String nữa , vậy thì làm thế để phía consumer ở service khác nhận được 1 cái message đó ạ. Tại vì em thấy listener nhận được cần truyền message có datatype giống cái datatype mà producer gửi lên , nhưng mà phía consumer của sercice khác lại không có ạ datatype này ạ ..
Mỗi topic chỉ nên chứa một data type nhất định. Nếu khác nhau thì em có thể tạo topic khác.
@@DevteriaChannel dạ. v nếu ở phía producer của service A push 1 message là datatype chỉ có ở serviceA nhưng phía consumer của service B không có datatype như ở service A thì Listener ở service B sử lí như thế nào ạ ?
mình cần truyền datatype gì vào param ở listener của phía consumer ạ
A ơi các service giao tiếp với nhau mà lỗi cần rollback thì dùng gì vậy ạ
Em tìm hiểu từ khoá Saga nhé
Rabbit MQ khác kalfka ở chỗ nào a nhỉ
Cơ bản nó cũng là message broker nhưng RabbitMQ cung cấp cơ chế routing message với nhiều tuỳ chọn hơn.