こんにちは、みんな、
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のドキュメントを読みました。
しかし、私がしたことの何が悪いのかわかりません。
ご協力いただきありがとうございます。
画像として添付されたログはあまり役に立ちません。それでも手元にある場合は、実際のログを確認することをお勧めします。元の投稿をバックティックで編集するか、ログを要旨としてアップロードしてリンクできます。
私が言えることから、あなたは古いKafkaブローカーに対して2.xストリームアプリを実行しようとしています。ただし、ログには引き続きエラーとして表示されるはずなので、詳細を確認するとトラブルシューティングに役立ちます。
また、参照用のストリームとカフカの互換性マトリックスもあります。
関連記事
- SpringCloudコントラクトベリファイアbaseClassMappingが300で機能しなくなりました
- Spring CloudGatewayはDiscoveryClientRouteDefinitionLocatorでは機能しません
- Spring Cloud Stream:条件が満たされた場合はSpecificRecordで、そうでない場合はGenericRecordで読み取る方法
- Spring Cloudデータフローローカルサーバージャー:javalangNoClassDefFoundError
- マイクロサービス間のKubernetes通信
- Spring MVCでカスタム検証を実行する方法は?
- アカウント間の安全な通信
- FirebaseStorageとCloudFirestore/Realtime Databaseの違いは何ですか?
- Spring Cloud Kafka:2つのプロセッサがアクティブな場合、出力ストリームのデータをシリアル化できません
- AndroidのCloudFirestoreからカスタムオブジェクトのリストを取得する方法
誰かが問題の解決を手伝ってくれました。
2.0.2バージョンのSpringでは、カスタムアプリケーションストリームが機能しませんでした。しかし、1.5.13バージョンのSpringを使用すると、すべてが機能しました。
それが一部の人々に役立つことを願っています。