【RabbitMQ】如何保證消息消費時的冪等性+如何處理消息丟失的問題

一、如何保證消息消費時的冪等性       這個問題可以等價於如何保證消費不被重複消費?爲什麼在消費隊列裏消費到了重複的數據。 1、kafak消費端可能導致的重複消費問題                              消費者準備提交offset,但還沒有提交的時候,消費者進程被重啓了。那麼此時已經消費過的數據offset還沒有提交。kafka也就不知道你消費了offset=153的那條
相關文章
相關標籤/搜索