Spring Cloud Gateway と Reactive Kafka を統合するプロトタイプを作成しています。私の目標は、投稿本文をカフカにプッシュすることです。Fluxにアクセスできます。これにより、ボディをチャンクで提供できる可能性があります。この DataBuffer の Flux を SenderRecord に変換し、これを kafka ノンブロッキングにプッシュする方法について、専門家のアドバイスが必要です。
DataBufferUtils.join を使用して、 DataBufferをマージして bytes[] を取得し、これを使用して SenderRecord を作成しようとしました。これに対するより良い方法はありますか (バイト配列の割り当てを回避できますか)?
実装の詳細: Kafka 用の Spring Cloud Gateway グローバル フィルターがあります (url 構造: kafka://<producer-template>?topic=<topicname>。次に、ボディ、すなわちフラックスを読み取り、kafkaSender.
ありがとうございました。