私たちは非同期通信に徹底的に使用される分散メッセージングミドルウェアとしてapache kafkaを実装しています。apache kafkaの機能のような相関IDの複製
私はkafkaブローカーにメッセージを公開し、その特定のメッセージへの返信を聞くことができるいくつかのユースケースを持っています（ウサギmqの相関IDを使用するような場合）。
私はapache kafkaプロトコルについて読んで、内部的に相関IDを使用しているようです。しかし、その相関IDをどこでも使っている例は見つけられませんでした。
apache kafkaでこれを行う方法があれば教えてください。
これは、ネットワーク通信プロトコルの一部です。ユーザーの要求 - 応答のシナリオに関するものではありません
Correlation Id in Apache kafka
。
あなたはビジネス要求に対する返信ビジネスを追跡するためにcorrelationKeyとしての一部を使用することを検討すべきです。
バージョン2.0以降（開発中）、Spring KafkaはApache Kafka 0.11のヘッダーをサポートしています。したがって、のハッキングの代わりに、相関の問題についていくつかのヘッダーを使用することができます。
request-replyが中心的な機能である場合、ゲートウェイ統合のためのSpring Integration Kafkaの進捗状況も確認できます。したがって、相関は非常に重要です：https://github.com/spring-projects/spring-integration-kafka/pull/162