RocketMQでメッセージの送信保証と消費保証を実現する方法、死信キューの役割
一、プロデューサーがメッセージを送信したことをどう保証するか？
まず重要な点:
プロデューサーが保証できるのは、メッセージが RocketMQ Broker に正常に送信されたことまでです。
プロデューサーは、コンシューマーが業務処理を完了したことまでは直接保証できません。
つまり RocketMQ は非同期モデルです:
Producer -> Broker -> Consumer
プロデューサーは ...
9月27日 23:04 投稿
Kafka コンシューマの冪等性を実現する実装手法
Kafka を扱う際、プロデューサ側の冪等性に注目が集まりがちですが、コンシューマ側の冪等性もシステムの信頼性を左右する重要な要素です。特に、ネットワーク障害やプロセスの再起動などにより同一メッセージが複数回配信される可能性がある分散環境では、コンシューマが冪等に動作しないと、データの重複登録や重複引き落としといった深刻な不整合を引き起こします。本稿 ...
5月30日 12:02 投稿