Spring Cloud Data Flow：カスタムアプリストリームとビルド済みアプリストリーム間の通信

bugfix> spring > 投稿

こんにちは、みんな、
Spring Cloud Data Flowに問題があります。事前に構築されたアプリケーションストリームとカスタムアプリケーションの間でデータを転送できません。

環境：
Kafkaバージョン：0.10.2.1（2.11 scalaバージョンを使用）
Spring Cloud Data Flowバージョン：1.5.0
スプリングブートバージョン：2.0.2

問題点：
https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#_custom_processor_applicationからtutoを実行しました
次に、transformer（プロセッサタイプ）という名前のカスタムアプリを登録しました。
画像
 
ストリームを作成し、カスタムアプリを使用して展開します。

-問題1：カスタムアプリケーションストリームの展開が終了しない。
画像

-問題2：事前に構築されたアプリケーションストリームとカスタムアプリケーション間でデータを転送できません。

トランスオーマーアプリの標準出力は次のとおりです。
画像
ログの標準出力（シンク）は次のとおりです。
画像 

試したこと：
-私もこれを試しましたが、同じ問題->カスタムストリームクラウドプロセッサ
-私は他のサイトから他の多くのトゥトを試しました。
-異なるバージョンのkafkaを試しました：1.1.0、1.0.1
-Spring Cloud StreamのドキュメントとSpring Cloud Data Flowのドキュメントを読みました。 しかし、私がしたことの何が悪いのかわかりません。

ご協力いただきありがとうございます。

spring

spring-cloud-stream

spring-cloud-dataflow

回答 2 件

  • 誰かが問題の解決を手伝ってくれました。

    2.0.2バージョンのSpringでは、カスタムアプリケーションストリームが機能しませんでした。しかし、1.5.13バージョンのSpringを使用すると、すべてが機能しました。

    それが一部の人々に役立つことを願っています。

  • 画像として添付されたログはあまり役に立ちません。それでも手元にある場合は、実際のログを確認することをお勧めします。元の投稿をバックティックで編集するか、ログを要旨としてアップロードしてリンクできます。

    私が言えることから、あなたは古いKafkaブローカーに対して2.xストリームアプリを実行しようとしています。ただし、ログには引き続きエラーとして表示されるはずなので、詳細を確認するとトラブルシューティングに役立ちます。

    また、参照用のストリームとカフカの互換性マトリックスもあります。

あなたの答え

関連記事