SCDFで2つの異なる出力チャネルにメッセージを送信する方法は？

Question

デフォルトのoutputチャネルを介してストリーム内のプロセッサにメッセージを送信するソースがあります。今私は別のチャネルを介して失敗メッセージを送信したいと思います。

私はSourceから拡張するバインド可能なインターフェイスを作成し、@Outputを使用して余分なチャンネルを追加する必要があると考えました。 SCDFが実際にこのチャンネルのカフカのトピックを作成するようにするにはどうすればよいですか？ IOW、ストリーム定義はどのように見えますか？

など。異なるチャネル/トピックを使用して、通常のoutputチャネル/カフカのトピック、およびsource > error-sinkを使用してsource | processorで

source | processor | sink source > error-sink

の線に沿って何か。

Answer 1

ダウンストリーム処理のエラーメッセージを追跡する必要がある場合は、Spring Cloud Streamに関連付けられたOOTB DLQ機構を使用できます。 RabbitとKafkaの両方でサポートされています。 Spring Cloud Data Flow（SCDF）でDLQをglobal settingまたはストリームごとに有効にできます。

もしもがの場合、カスタムチャネルを定義してメッセージを別々に扱うようにしたい場合は、sampleのようなカスタムインターフェイスを作成する必要があります。

ストリームをSCDFにデプロイするときに、それぞれ、spring.cloud.stream.kafka.bindings.<channelName>.producerとspring.cloud.stream.kafka.bindings.<channelName>.consumerというバインディングプロパティを使用して、プロデューサとコンシューマ間の宛先を上書きできます。

EDIT：

上記のアプローチがありますけれどもが、私は春のクラウドストリームリード（@マリウス-bogoevici）からはるかに簡単な解決策について学びました。

すでに使用可能なデフォルトのエラー・チャネルがあり、Spring Integrationがそれをサポートしています。

これで、あなたのアプリケーションでカスタムメッセージをデフォルトのエラーチャネルに送信することができます：@Autowire @Qualifier("errorChannel")。実際、このサポートはでもあり、はすべてのOOTBアプリケーションで利用できます。

このエラーチャネルの宛先は、spring.cloud.stream.bindings.error.destination=errorchannel-testでオーバーライドできます.SCDFでは、ストリーム配信時に--propertiesを渡します。例えば

：

ストリームのfoo --definitionを作成する "MYSOURCEは|ログ"

ストリームfooの--properties「app.mysource.spring.cloud.stream.bindings.error.destinationを展開= errorchannel-test "