1
マイクロサービスのプロジェクトでApache Kafkaを使用する必要があります。私は1つのマイクロサービスがデータを作り、もう1つは同じデータを消費する必要があります。どのように私は2つのサービスの間で同じようにカフカを作ることができますプロデューサーコンシューマーを使用したKafkaとマイクロサービス
A
答えて
0
私はあなたが必要としている通りにSpring Cloud Streamを見てお勧めします。ドキュメントから
：メッセージ駆動型microservicesを構築するための
フレームワーク。 Spring Cloud Streamは、Springブートを基盤にしてDevOpsフレンドリーなマイクロサービスアプリケーションを作成し、Spring Integrationを使用してメッセージブローカーに接続します。 Spring Cloud Streamは、複数のミドルウェア・ベンダー間で永続的なpub/subセマンティクス、コンシューマ・グループおよびパーティションの概念を導入して、メッセージ・ブローカーの有望な構成を提供します。この構成は、ストリーム処理アプリケーションを作成するための基礎を提供します。
メインアプリケーションに@EnableBindingを追加すると、メッセージブローカーにすぐに接続でき、メソッドに@StreamListenerを追加することで、ストリーム処理のイベントを受け取ることができます。