イベント駆動アーキテクチャとは？Kafka・RabbitMQでマイクロサービスを疎結合に設計する方法

マイクロサービスが増えると「どのサービスが何を呼ぶか」が複雑化します。イベント駆動アーキテクチャ（EDA）はサービス間の直接呼び出しをやめ、イベントを介した疎結合設計でこの問題を解決します。

イベント駆動アーキテクチャとは

従来のRPCアーキテクチャではサービスAがサービスBを直接呼びます。EDAでは：

メリット： 疎結合・スケールアウト容易・失敗の局所化

ツール	保持期間	スループット	用途	特徴
Kafka	永続	◎	ストリーミング・ログ集約	最高スループット・保持ありリプレイ可
RabbitMQ	一時	○	タスクキュー・RPC	シンプル・AMQP標準
NATS	一時/JetStream	◎	マイクロサービス・IoT	超軽量・Go製
Redis Streams	永続	○	軽量キュー	Redisで完結

Kafka（公式サイト↗・GitHub↗）はLinkedInが開発してOSSになった分散メッセージングシステムです。1秒間に数百万件のイベントを処理でき、イベントを永続保存してリプレイできます。

Kafkaのセットアップと基本的なプロデューサー/コンシューマーのコードはKafka公式ドキュメント↗を参照。またRabbitMQ公式サイト↗もタスクキューの参考になります。

DevOps関連OSSはDevOpsカテゴリから。データパイプラインのETLツールはETLツール比較記事も参照。

RabbitMQ（公式サイト↗・GitHub↗）はAMQPプロトコルのメッセージブローカーOSSです。Kafkaより設定がシンプルで、タスクキュー（メール送信・画像処理等）の非同期処理に最適です。

EDAと組み合わせるパターンとして「イベントソーシング」があります。DBのデータを直接更新するのではなく、すべての変更をイベントとして記録し、現在の状態はイベントの集積で導きます。

2026年のメッセージブローカーOSS：大規模ストリーミングはKafka、シンプルなタスクキューはRabbitMQが2大選択肢です。

タスクキュー（注文処理・メール送信等）はRabbitMQがシンプルです。ログ集約・リアルタイム分析・イベントリプレイが必要な場合はKafkaです。初めてならRabbitMQから始めることを推奨します。

Kafka単体のセットアップはRedpanda（Kafkaプロトコル互換・軽量版）を使うと簡単です。本番クラスター構成はKRaft（ZooKeeper不要）モードが2024年以降の標準です。

はい。RabbitMQはSQS相当、Kafkaはキネシス相当のOSS代替です。ElasticMQ（SQSプロトコル互換）もローカル開発に便利です。