春クラウドストリームカフカ：カフカの出力チャネルにメッセージを書き込み「入力」

Question

私はプロデューサー（Source）を持っているため、重複@StreamListenerマッピングは、そのプロデューサーは、オブジェクトの異なるタイプを送信します。消費者側では（Sink）、同じ入力チャンネルに複数の@Streamlistenerメソッドをそれぞれ別のパラメータタイプで持たせたいと思っていますが、現在は動作していません。Duplicate @StreamListener mapping for 'input'です。ここで

は私のコンシューマコードです：

@StreamListener(Sink.INPUT) 
public void on(PostUpvotedEvent event) { 

} 

@StreamListener(Sink.INPUT) 
public void on(PostDownvotedEvent event) { 

} 

が呼ばれるようにどの方法を選択するメッセージタイプにテストする単一@StreamListenerメソッドを持つよりもそれを行うには良い解決策はありますか？

Answer 1

複数の@StreamListener複数の同じバインドされた要素のメソッドは、現在サポートされていません。インバウンドチャネルに複数の加入者を登録する場合は、このようにサポートすることをお勧めします。

これが現在許可されていない理由は、いくつかの本当の理由がある場合もあります機能要求here