最新の安定バージョンについては、spring-cloud-stream 4.2.1 を使用してください。 |
エラーチャネル
バージョン 1.3 以降、バインダーは各コンシューマー宛先のエラーチャネルに無条件に例外を送信し、非同期プロデューサー送信エラーをエラーチャネルに送信するように構成することもできます。詳細については、エラー処理に関するこのセクションを参照してください。
送信失敗の ErrorMessage
のペイロードは、次のプロパティを持つ KafkaSendFailureException
です。
failedMessage
: 送信に失敗した Spring メッセージングMessage<?>
。record
:failedMessage
から作成された生のProducerRecord
プロデューサー例外 ( デッドレタートピックへの送信など) は自動的に処理されません。これらの例外は、独自の Spring Integration フローで使用できます。