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のドキュメントを読みました。 しかし、私がしたことの何が悪いのかわかりません。

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

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

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

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

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

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

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

あなたの答え